code: 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;
      }
docs: Create a new transport endpoint
  @return a new transport endpoint