org.codehaus.xfire.transport.jms
Class JMSChannel

java.lang.Object
  extended by org.codehaus.xfire.transport.AbstractChannel
      extended by 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
 
Constructor Summary
JMSChannel(java.lang.String uri, JMSTransport transport)
           
 
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
 

Field Detail

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
Constructor Detail

JMSChannel

public JMSChannel(java.lang.String uri,
                  JMSTransport transport)
Method Detail

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-2011. All Rights Reserved.