org.objectweb.joram.client.connector

Class OutboundConnection

Implemented Interfaces:
javax.jms.Connection
Known Direct Subclasses:
OutboundQueueConnection, OutboundTopicConnection

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

An OutboundConnection instance is a handler for a physical connection to an underlying JORAM server, allowing a component to transparently use this physical connection possibly within a transaction (local or global).

Method Summary

void
cleanup()
close all session.
void
close()
Requests to close the physical connection.
boolean
cnxEquals(Object obj)
returns true if the parameter is a Connection instance sharing the same proxy identifier and connection key.
ConnectionConsumer
createConnectionConsumer(Destination destination, String messageSelector, ServerSessionPool sessionPool, int maxMessages)
Forbidden call on an application or component's outbound connection, throws a IllegalStateException instance.
ConnectionConsumer
createDurableConnectionConsumer(Topic topic, String subscriptionName, String messageSelector, ServerSessionPool sessionPool, int maxMessages)
Forbidden call on an application or component's outbound connection, throws a IllegalStateException instance.
Session
createSession(boolean transacted, int acknowledgeMode)
Returns the unique authorized JMS session per connection wrapped in an OutboundSession instance.
String
getClientID()
Forbidden call on an application or component's outbound connection, throws a IllegalStateException instance.
ExceptionListener
getExceptionListener()
Forbidden call on an application or component's outbound connection, throws a IllegalStateException instance.
ConnectionMetaData
getMetaData()
Delegates the call to the wrapped JMS connection.
void
setClientID(String clientID)
Forbidden call on an application or component's outbound connection, throws a IllegalStateException instance.
void
setExceptionListener(ExceptionListener listener)
Forbidden call on an application or component's outbound connection, throws a IllegalStateException instance.
void
start()
Delegates the call to the wrapped JMS connection.
void
stop()
Forbidden call on an application or component's outbound connection, throws a IllegalStateException instance.
String
toString()

Method Details

cleanup

public void cleanup()
close all session.


close

public void close()
            throws JMSException
Requests to close the physical connection.


cnxEquals

public boolean cnxEquals(Object obj)
returns true if the parameter is a Connection instance sharing the same proxy identifier and connection key.


createConnectionConsumer

public ConnectionConsumer createConnectionConsumer(Destination destination,
                                                   String messageSelector,
                                                   ServerSessionPool sessionPool,
                                                   int maxMessages)
            throws JMSException
Forbidden call on an application or component's outbound connection, throws a IllegalStateException instance.


createDurableConnectionConsumer

public ConnectionConsumer createDurableConnectionConsumer(Topic topic,
                                                          String subscriptionName,
                                                          String messageSelector,
                                                          ServerSessionPool sessionPool,
                                                          int maxMessages)
            throws JMSException
Forbidden call on an application or component's outbound connection, throws a IllegalStateException instance.


createSession

public Session createSession(boolean transacted,
                             int acknowledgeMode)
            throws JMSException
Returns the unique authorized JMS session per connection wrapped in an OutboundSession instance.


getClientID

public String getClientID()
            throws JMSException
Forbidden call on an application or component's outbound connection, throws a IllegalStateException instance.


getExceptionListener

public ExceptionListener getExceptionListener()
            throws JMSException
Forbidden call on an application or component's outbound connection, throws a IllegalStateException instance.


getMetaData

public ConnectionMetaData getMetaData()
            throws JMSException
Delegates the call to the wrapped JMS connection.


setClientID

public void setClientID(String clientID)
            throws JMSException
Forbidden call on an application or component's outbound connection, throws a IllegalStateException instance.


setExceptionListener

public void setExceptionListener(ExceptionListener listener)
            throws JMSException
Forbidden call on an application or component's outbound connection, throws a IllegalStateException instance.


start

public void start()
            throws JMSException
Delegates the call to the wrapped JMS connection.


stop

public void stop()
            throws JMSException
Forbidden call on an application or component's outbound connection, throws a IllegalStateException instance.


toString

public String toString()


Copyright B) 2004 Scalagent - All rights reserved