@ Override public void started ( ServiceBroker broker ) throws Exception { super . started ( broker ) ; // Process config ServiceBrokerConfig cfg = broker . getConfig ( ) ; namespace = cfg . getNamespace ( ) ; if ( namespace != null && ! namespace . isEmpty ( ) ) { prefix = prefix + ' ' + namespace ; } nodeID = broker . getNodeID ( ) ; // Log serializer info serializer . started ( broker ) ; logger . info ( nameOf ( this , true ) + " will use " + nameOf ( serializer , true ) + ' ' ) ; // Get components executor = cfg . getExecutor ( ) ; scheduler = cfg . getScheduler ( ) ; registry = cfg . getServiceRegistry ( ) ; monitor = cfg . getMonitor ( ) ; eventbus = cfg . getEventbus ( ) ; uid = cfg . getUidGenerator ( ) ; // Set channel names eventChannel = channel ( PACKET_EVENT , nodeID ) ; requestChannel = channel ( PACKET_REQUEST , nodeID ) ; responseChannel = channel ( PACKET_RESPONSE , nodeID ) ; discoverBroadcastChannel = channel ( PACKET_DISCOVER , null ) ; discoverChannel = channel ( PACKET_DISCOVER , nodeID ) ; infoBroadcastChannel = channel ( PACKET_INFO , null ) ; infoChannel = channel ( PACKET_INFO , nodeID ) ; disconnectChannel = channel ( PACKET_DISCONNECT , null ) ; heartbeatChannel = channel ( PACKET_HEARTBEAT , null ) ; pingChannel = channel ( PACKET_PING , nodeID ) ; pongChannel = channel ( PACKET_PONG , nodeID ) ; }
Initializes transporter instance .