org.directwebremoting.jms
Class DwrConnection

java.lang.Object
  extended by org.directwebremoting.jms.DwrConnection
All Implemented Interfaces:
javax.jms.Connection

public class DwrConnection
extends java.lang.Object
implements javax.jms.Connection

An implementation of Connection for DWR

Author:
Joe Walker [joe at getahead dot ltd dot uk]

Constructor Summary
DwrConnection()
           
 
Method Summary
 void close()
           
 javax.jms.ConnectionConsumer createConnectionConsumer(javax.jms.Destination destination, java.lang.String messageSelector, javax.jms.ServerSessionPool sessionPool, int maxMessages)
           
 javax.jms.ConnectionConsumer createDurableConnectionConsumer(javax.jms.Topic topic, java.lang.String subscriptionName, java.lang.String messageSelector, javax.jms.ServerSessionPool sessionPool, int maxMessages)
           
 DwrSession createSession(boolean transacted, int acknowledgeMode)
           
 java.lang.String getClientID()
           
 javax.jms.ExceptionListener getExceptionListener()
           
 DwrConnectionMetaData getMetaData()
           
 ServerContext getServerContext()
           
 State getState()
          Children need to know if they can send messages.
 void setClientID(java.lang.String clientId)
           
 void setExceptionListener(javax.jms.ExceptionListener listener)
           
 void setServerContext(ServerContext serverContext)
           
 void start()
           
 void stop()
           
 
Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

DwrConnection

public DwrConnection()
Method Detail

createSession

public DwrSession createSession(boolean transacted,
                                int acknowledgeMode)
                         throws javax.jms.JMSException
Specified by:
createSession in interface javax.jms.Connection
Throws:
javax.jms.JMSException

createConnectionConsumer

public javax.jms.ConnectionConsumer createConnectionConsumer(javax.jms.Destination destination,
                                                             java.lang.String messageSelector,
                                                             javax.jms.ServerSessionPool sessionPool,
                                                             int maxMessages)
                                                      throws javax.jms.JMSException
Specified by:
createConnectionConsumer in interface javax.jms.Connection
Throws:
javax.jms.JMSException

createDurableConnectionConsumer

public javax.jms.ConnectionConsumer createDurableConnectionConsumer(javax.jms.Topic topic,
                                                                    java.lang.String subscriptionName,
                                                                    java.lang.String messageSelector,
                                                                    javax.jms.ServerSessionPool sessionPool,
                                                                    int maxMessages)
                                                             throws javax.jms.JMSException
Specified by:
createDurableConnectionConsumer in interface javax.jms.Connection
Throws:
javax.jms.JMSException

getMetaData

public DwrConnectionMetaData getMetaData()
                                  throws javax.jms.JMSException
Specified by:
getMetaData in interface javax.jms.Connection
Throws:
javax.jms.JMSException

start

public void start()
           throws javax.jms.JMSException
Specified by:
start in interface javax.jms.Connection
Throws:
javax.jms.JMSException

stop

public void stop()
          throws javax.jms.JMSException
Specified by:
stop in interface javax.jms.Connection
Throws:
javax.jms.JMSException

close

public void close()
           throws javax.jms.JMSException
Specified by:
close in interface javax.jms.Connection
Throws:
javax.jms.JMSException

setClientID

public void setClientID(java.lang.String clientId)
                 throws javax.jms.JMSException
Specified by:
setClientID in interface javax.jms.Connection
Throws:
javax.jms.JMSException

getClientID

public java.lang.String getClientID()
                             throws javax.jms.JMSException
Specified by:
getClientID in interface javax.jms.Connection
Throws:
javax.jms.JMSException

setExceptionListener

public void setExceptionListener(javax.jms.ExceptionListener listener)
                          throws javax.jms.JMSException
Specified by:
setExceptionListener in interface javax.jms.Connection
Throws:
javax.jms.JMSException

getExceptionListener

public javax.jms.ExceptionListener getExceptionListener()
                                                 throws javax.jms.JMSException
Specified by:
getExceptionListener in interface javax.jms.Connection
Throws:
javax.jms.JMSException

getState

public State getState()
Children need to know if they can send messages.

Returns:
Has Connection.start() been called

getServerContext

public ServerContext getServerContext()
Returns:
the servletContext

setServerContext

public void setServerContext(ServerContext serverContext)
Parameters:
serverContext - the servletContext to set

Copyright 2008