public synchronized PacketTransportEndpoint createEndpoint ( ) throws JMSException { if ( closed || transport . isClosed ( ) ) throw new FFMQException ( "Transport is closed" , "TRANSPORT_CLOSED" ) ; PacketTransportEndpoint endpoint = new PacketTransportEndpoint ( nextEndpointId ++ , this ) ; registeredEndpoints . put ( Integer . valueOf ( endpoint . getId ( ) ) , endpoint ) ; return endpoint ; }
Create a new transport endpoint