Connection state

Handle connection state changes in pub/sub applications.