oracle.jms

Class AQjmsConnection

java.lang.Object

oracle.jms.AQjmsObject

oracle.jms.AQjmsConnection

All Implemented Interfaces:

Connection, QueueConnection, TopicConnection

Direct Known Subclasses:

AQjmsXAConnection

public class AQjmsConnection
extends oracle.jms.AQjmsObject
implements QueueConnection, TopicConnection

This is an Oracle class which implements javax.jms.QueueConnection and javax.jms.TopicConnection.

Method Summary

Modifier and Type	Method and Description
void	close() Public for test harness purposes
ConnectionConsumer	createConnectionConsumer(Destination destination, java.lang.String messageSelector, ServerSessionPool sessionPool, int maxMessages) Creates a connection consumer for this connection (optional operation).
ConnectionConsumer	createConnectionConsumer(Queue queue, java.lang.String messageSelector, ServerSessionPool sessionPool, int maxMessages) This method is not supported in the current release.
ConnectionConsumer	createConnectionConsumer(Topic topic, java.lang.String messageSelector, ServerSessionPool sessionPool, int maxMessages) Creates a connection consumer for this connection.
ConnectionConsumer	createDurableConnectionConsumer(Topic topic, java.lang.String subscriptionName, java.lang.String messageSelector, ServerSessionPool sessionPool, int maxMessages) Creates a durable connection consumer for this connection.
QueueSession	createQueueSession(boolean transacted, int acknowledgeMode) Creates a queue session.
Session	createSession(boolean transacted, int acknowledgeMode) Creates a Session object.
TopicSession	createTopicSession(boolean transacted, int acknowledgeMode) Creates a TopicSession.
java.lang.String	getClientID() Gets this connection's client identifier.
Session	getCurrentJmsSession() Returns the current open JMS session for this connection.
ExceptionListener	getExceptionListener() Gets this connection's ExceptionListener.
ConnectionMetaData	getMetaData() Gets this connection's meta data.
oracle.jdbc.pool.OracleOCIConnectionPool	getOCIConnectionPool() Gets the underlying connection pool for this connection.
void	setClientID(java.lang.String clientID) Sets this connection's client identifier.
void	setExceptionListener(ExceptionListener listener) Sets this connection's ExceptionListener.
void	start() Starts (or restarts) a connection's delivery of incoming messages.
void	stop() Temporarily stops a connection's delivery of incoming messages.

Methods inherited from class oracle.jms.AQjmsObject

checkClosed, children, finalize, getID, getParent, isOpen, localClose, preClose

Methods inherited from class java.lang.Object

clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

getClientID

public java.lang.String getClientID()
                             throws JMSException

Gets this connection's client identifier.

Specified by:

getClientID in interface Connection

Returns:

the unique client identifier

Throws:

JMSException - if the client ID for this connection is not returned due to some error.

setClientID

public void setClientID(java.lang.String clientID)
                 throws JMSException

Sets this connection's client identifier.

Specified by:

setClientID in interface Connection

Parameters:

clientID - the unique client identifier

Throws:

JMSException - if the client ID for this connection is not set due to some error.

IllegalStateException - if the JMS client attempts to set a connection's client ID at the wrong time or when it has been administratively configured.

getMetaData

public ConnectionMetaData getMetaData()
                               throws JMSException

Gets this connection's meta data.

Specified by:

getMetaData in interface Connection

Returns:

the connection meta data

Throws:

JMSException - if the connection meta-data is not retrieved due to some error.

See Also:

ConnectionMetaData

setExceptionListener

public void setExceptionListener(ExceptionListener listener)
                          throws JMSException

Sets this connection's ExceptionListener.

Specified by:

setExceptionListener in interface Connection

Parameters:

listener - the exception listener

Throws:

JMSException - if the exception listener is not set due to some error.

getExceptionListener

public ExceptionListener getExceptionListener()
                                       throws JMSException

Gets this connection's ExceptionListener.

Specified by:

getExceptionListener in interface Connection

Returns:

the ExceptionListener for this connection, or null. if no ExceptionListener is associated with this connection.

Throws:

JMSException - if the exception listener is not retrieved due to some error.

See Also:

Connection.setExceptionListener(javax.jms.ExceptionListener)

start

public void start()
           throws JMSException

Starts (or restarts) a connection's delivery of incoming messages. Restarting begins with the oldest unacknowledged message. Starting a started connection is ignored.

Specified by:

start in interface Connection

Throws:

JMSException - if message delivery is not started due to some error.

See Also:

Connection.start()

stop

public void stop()
          throws JMSException

Temporarily stops a connection's delivery of incoming messages. The connection can be restarted using the AQjmsConnection.start() method. When stopped, delivery to all of the connection's message consumers is inhibited: synchronous receives block and messages are not delivered to message listeners. A default timeout of 60 minutes is set to disable the MessageListener(s) set on the message consumer(s), which can by configured by setting the system property oracle.jms.notificationTimeOut in milli seconds, to an appropriate value. If there is a time out while disabling the MessageLister(s), the Connection will be started to keep the system in a good condition. After stop is called there may still be some messages delivered. Stopping a connection has no affect on its ability to send messages. Stopping a stopped connection is ignored.

Specified by:

stop in interface Connection

Throws:

JMSException - if message delivery is not stopped due to some error.

See Also:

Connection.stop()

close

public void close()
           throws JMSException

Description copied from class: oracle.jms.AQjmsObject

Public for test harness purposes

Specified by:

close in interface Connection

Overrides:

close in class oracle.jms.AQjmsObject

Throws:

JMSException - if the JMS provider fails to close the connection due to some internal error. For example, a failure to release resources or to close a socket connection can cause this exception to be thrown.

createQueueSession

public QueueSession createQueueSession(boolean transacted,
                                       int acknowledgeMode)
                                throws JMSException

Creates a queue session.

Specified by:

createQueueSession in interface QueueConnection

Parameters:

transacted - is session transacted?

acknowledgeMode - acknowledgement mode

Returns:

a newly created queue session

Throws:

JMSException - if queue session creation fails.

See Also:

Session.AUTO_ACKNOWLEDGE, Session.CLIENT_ACKNOWLEDGE, Session.DUPS_OK_ACKNOWLEDGE

createConnectionConsumer

public ConnectionConsumer createConnectionConsumer(Queue queue,
                                                   java.lang.String messageSelector,
                                                   ServerSessionPool sessionPool,
                                                   int maxMessages)
                                            throws JMSException

This method is not supported in the current release.

Specified by:

createConnectionConsumer in interface QueueConnection

Parameters:

queue - the queue to access

messageSelector - only messages with properties matching the message selector expression are delivered. A value of null or an empty string indicates that there is no message selector for the message consumer.

sessionPool - the server session pool to associate with this connection consumer

maxMessages - the maximum number of messages that can be assigned to a server session at one time

Returns:

the connection consumer

Throws:

JMSException - NOT_SUPPORTED

See Also:

ConnectionConsumer

createTopicSession

public TopicSession createTopicSession(boolean transacted,
                                       int acknowledgeMode)
                                throws JMSException

Creates a TopicSession.

Specified by:

createTopicSession in interface TopicConnection

Parameters:

transacted - if true, the session is transacted.

acknowledgeMode - indicates whether the consumer or the client will acknowledge any messages it receives. This parameter is ignored if the session is transacted.

Returns:

a newly created topic session

Throws:

JMSException - if session creation fails due to some error or lack of support for the specific transaction and acknowledgement mode.

See Also:

Session.AUTO_ACKNOWLEDGE, Session.CLIENT_ACKNOWLEDGE, Session.DUPS_OK_ACKNOWLEDGE

createConnectionConsumer

public ConnectionConsumer createConnectionConsumer(Topic topic,
                                                   java.lang.String messageSelector,
                                                   ServerSessionPool sessionPool,
                                                   int maxMessages)
                                            throws JMSException

Creates a connection consumer for this connection. This is an expert facility not used by regular JMS clients. This method is not supported in the current release.

Specified by:

createConnectionConsumer in interface TopicConnection

Parameters:

topic - the topic to access

messageSelector - only messages with properties matching the message selector expression are delivered. A value of null or an empty string indicates that there is no message selector for the message consumer.

sessionPool - the server session pool to associate with this connection consumer

maxMessages - the maximum number of messages that can be assigned to a server session at one time

Returns:

the connection consumer

Throws:

JMSException - NOT_SUPPORTED

See Also:

ConnectionConsumer

createDurableConnectionConsumer

public ConnectionConsumer createDurableConnectionConsumer(Topic topic,
                                                          java.lang.String subscriptionName,
                                                          java.lang.String messageSelector,
                                                          ServerSessionPool sessionPool,
                                                          int maxMessages)
                                                   throws JMSException

Creates a durable connection consumer for this connection. This is an expert facility not used by regular JMS clients. This method is not supported in the current release.

Specified by:

createDurableConnectionConsumer in interface Connection

Specified by:

createDurableConnectionConsumer in interface TopicConnection

Parameters:

topic - topic to access

subscriptionName - durable subscription name

messageSelector - only messages with properties matching the message selector expression are delivered. A value of null or an empty string indicates that there is no message selector for the message consumer.

sessionPool - the server session pool to associate with this durable connection consumer

maxMessages - the maximum number of messages that can be assigned to a server session at one time

Returns:

the durable connection consumer

Throws:

JMSException - NOT_SUPPORTED

See Also:

ConnectionConsumer

getCurrentJmsSession

public Session getCurrentJmsSession()

Returns the current open JMS session for this connection.

Important: This method will be deprecated in a future release

Returns:

the current open JMS session, or null if no JMS session is currently available

getOCIConnectionPool

public oracle.jdbc.pool.OracleOCIConnectionPool getOCIConnectionPool()

Gets the underlying connection pool for this connection.

Returns:

the oracle.jdbc.pool.OracleOCIConnectionPool pool used to create this connection or null

createSession

public Session createSession(boolean transacted,
                             int acknowledgeMode)
                      throws JMSException

Creates a Session object.

Specified by:

createSession in interface Connection

Parameters:

transacted - indicates whether the session is transacted

acknowledgeMode - indicates whether the consumer or the client will acknowledge any messages it receives; ignored if the session is transacted. Legal values are Session.AUTO_ACKNOWLEDGE, Session.CLIENT_ACKNOWLEDGE, and Session.DUPS_OK_ACKNOWLEDGE.

Returns:

a newly created session

Throws:

JMSException - if session creation fails due to some error or lack of support for the specific transaction and acknowledgement mode.

Since:

1.1

See Also:

Session.AUTO_ACKNOWLEDGE, Session.CLIENT_ACKNOWLEDGE, Session.DUPS_OK_ACKNOWLEDGE

createConnectionConsumer

public ConnectionConsumer createConnectionConsumer(Destination destination,
                                                   java.lang.String messageSelector,
                                                   ServerSessionPool sessionPool,
                                                   int maxMessages)
                                            throws JMSException

Creates a connection consumer for this connection (optional operation). This is an expert facility not used by regular JMS clients. This method is not supported in the current release.

Specified by:

createConnectionConsumer in interface Connection

Parameters:

destination - the destination to access

messageSelector - only messages with properties matching the message selector expression are delivered. A value of null or an empty string indicates that there is no message selector for the message consumer.

sessionPool - the server session pool to associate with this connection consumer

maxMessages - the maximum number of messages that can be assigned to a server session at one time

Returns:

the connection consumer

Throws:

JMSException - NOT_SUPPORTED

See Also:

ConnectionConsumer