| java.lang.Object org.objectweb.celtix.bus.transports.jms.JMSTransportBase org.objectweb.celtix.bus.transports.jms.JMSServerTransport
Inner Class :class JMSListenerThread extends Thread | |
Inner Class :static class JMSExecutor implements Runnable | |
Method Summary | |
public void | activate(ServerTransportCallback transportCB) | public OutputStreamMessageContext | createOutputStreamContext(MessageContext context) | public void | deactivate() | public void | finalPrepareOutputStreamContext(OutputStreamMessageContext context) | public JMSServerBehaviorPolicyType | getJMSServerBehaviourPolicy() | public Queue | getReplyToDestination(OutputStreamMessageContext context, Message message) | protected void | incoming(Message message) Helper method to process incoming message. | public Message | marshalResponse(Message message, OutputStreamMessageContext context, PooledSession replySession) | public void | postDispatch(MessageContext bindingContext, OutputStreamMessageContext context) | public void | processEvent(BusEvent e) | public OutputStreamMessageContext | rebase(MessageContext context, EndpointReferenceType decoupledResponseEndpoint) | public void | sendResponse(OutputStreamMessageContext context, Message request, Message reply, QueueSender sender, Queue replyTo) | public void | setReplyCorrelationID(Message message, Message reply) | public void | shutdown() |
JMSServerTransport | public JMSServerTransport(Bus b, EndpointReferenceType address) throws WSDLException(Code) | | |
getJMSServerBehaviourPolicy | public JMSServerBehaviorPolicyType getJMSServerBehaviourPolicy()(Code) | | |
incoming | protected void incoming(Message message) throws IOException(Code) | | Helper method to process incoming message.
Parameters: message - the incoming message |
sendResponse | public void sendResponse(OutputStreamMessageContext context, Message request, Message reply, QueueSender sender, Queue replyTo) throws JMSException(Code) | | |
setReplyCorrelationID | public void setReplyCorrelationID(Message message, Message reply) throws JMSException(Code) | | |
shutdown | public void shutdown()(Code) | | |
|
|