org.codehaus.xfire.transport.jms
Class JMSChannel
java.lang.Object
org.codehaus.xfire.transport.AbstractChannel
org.codehaus.xfire.transport.jms.JMSChannel
- All Implemented Interfaces:
- javax.jms.MessageListener, org.codehaus.xfire.transport.Channel
public class JMSChannel
- extends org.codehaus.xfire.transport.AbstractChannel
- implements javax.jms.MessageListener
Field Summary |
static java.lang.String |
JMS_URI
|
static java.lang.String |
REPLY_TO
|
Fields inherited from interface org.codehaus.xfire.transport.Channel |
BACKCHANNEL_URI, OUTPUTSTREAM, PASSWORD, USERNAME |
Method Summary |
void |
close()
|
protected javax.jms.MessageConsumer |
createConsumer()
|
void |
onMessage(javax.jms.Message message)
|
void |
open()
|
void |
send(org.codehaus.xfire.MessageContext context,
org.codehaus.xfire.exchange.OutMessage message)
|
Methods inherited from class org.codehaus.xfire.transport.AbstractChannel |
getEndpoint, getTransport, getUri, isAsync, receive, setEndpoint, setTransport, setUri |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
REPLY_TO
public static final java.lang.String REPLY_TO
- See Also:
- Constant Field Values
JMS_URI
public static final java.lang.String JMS_URI
- See Also:
- Constant Field Values
JMSChannel
public JMSChannel(java.lang.String uri,
JMSTransport transport)
open
public void open()
throws javax.jms.JMSException
- Specified by:
open
in interface org.codehaus.xfire.transport.Channel
- Throws:
javax.jms.JMSException
createConsumer
protected javax.jms.MessageConsumer createConsumer()
throws javax.jms.JMSException
- Throws:
javax.jms.JMSException
send
public void send(org.codehaus.xfire.MessageContext context,
org.codehaus.xfire.exchange.OutMessage message)
throws org.codehaus.xfire.fault.XFireFault
- Specified by:
send
in interface org.codehaus.xfire.transport.Channel
- Throws:
org.codehaus.xfire.fault.XFireFault
onMessage
public void onMessage(javax.jms.Message message)
- Specified by:
onMessage
in interface javax.jms.MessageListener
close
public void close()
- Specified by:
close
in interface org.codehaus.xfire.transport.Channel
- Overrides:
close
in class org.codehaus.xfire.transport.AbstractChannel
Copyright © 2004-2010. All Rights Reserved.