com.ibm.ecm.configuration

Class DatabaseMessageQueue

java.lang.Object

com.ibm.ecm.configuration.DatabaseMessageQueue

All Implemented Interfaces:

com.ibm.ecm.event.MessageQueue

public class DatabaseMessageQueue
extends java.lang.Object
implements com.ibm.ecm.event.MessageQueue

EventLog database table helper methods

Since:

3.0.11

Constructor Summary

Constructors

Constructor and Description
DatabaseMessageQueue()

Method Summary

Modifier and Type	Method and Description
boolean	isAvailable()
ForwardedMessage[]	pullMessages(java.lang.String instanceId)
void	pushMessage(ForwardedMessage message, java.lang.String instanceId) Adds a message to the database When rows are added to the table, the "ID" column will be populated automatically.
void	shutdown() Shut down the message queue

Methods inherited from class java.lang.Object

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

Constructor Detail

DatabaseMessageQueue

public DatabaseMessageQueue()

Method Detail

isAvailable

public boolean isAvailable()

Specified by:

isAvailable in interface com.ibm.ecm.event.MessageQueue

Returns:

true is the message queue is available

pullMessages

public ForwardedMessage[] pullMessages(java.lang.String instanceId)

Specified by:

pullMessages in interface com.ibm.ecm.event.MessageQueue

Parameters:

instanceId -

Returns:

An array of messages

pushMessage

public void pushMessage(ForwardedMessage message,
                        java.lang.String instanceId)

Adds a message to the database When rows are added to the table, the "ID" column will be populated automatically. The "EnqueueTime" value will be set to the current date/time (in UTC) when the insert statement is executed

Specified by:

pushMessage in interface com.ibm.ecm.event.MessageQueue

Parameters:

message -

instanceId -

shutdown

public void shutdown()

Shut down the message queue

Specified by:

shutdown in interface com.ibm.ecm.event.MessageQueue