Package COM.activesw.api.client

Class BrokerLockedQueueBrowserUtil

java.lang.Object

COM.activesw.api.client.BrokerQueueBrowserImpl

COM.activesw.api.client.BrokerLockedQueueBrowserUtil

All Implemented Interfaces:

BrokerLockedQueueBrowser, BrokerQueueBrowser

public class BrokerLockedQueueBrowserUtil
extends BrokerQueueBrowserImpl
implements BrokerLockedQueueBrowser

This class provides queue browsing methods for locked queue browsing.

Method Summary

Modifier and Type	Method	Description
protected BrokerException	createException(BrokerQueueBrowserException ex)
int	deleteEvents(long[] seqns)	Delete events in the queue.
void	insertEventsAtHead(BrokerEvent[] events)	Insert events in into the queue.
void	insertEventsAtTail(BrokerEvent[] events)	Insert events in into the queue.
void	modifyEvents(long[] seqns, BrokerEvent[] events)	Modify events in the queue.

Methods inherited from class COM.activesw.api.client.BrokerQueueBrowserImpl

browseEvents, closeQueueBrowser, getBrowserInfo, getFilters, resetFilters, setFilter, setFilters, setPosition

Methods inherited from class java.lang.Object

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

Methods inherited from interface COM.activesw.api.client.BrokerQueueBrowser

browseEvents, closeQueueBrowser, getBrowserInfo, getFilters, resetFilters, setFilter, setFilters, setPosition

Method Detail

modifyEvents

public void modifyEvents(long[] seqns,
                         BrokerEvent[] events)
                  throws BrokerException

Description copied from interface: BrokerLockedQueueBrowser

Modify events in the queue. The events are identified by the specified receipt sequence numbers for an in-place update in the queue.

Specified by:

modifyEvents in interface BrokerLockedQueueBrowser

Parameters:

seqns - An array of sequence numbers that identify the events to be modified in the queue.

events - An array of BrokerEvent that will be updated in place of the events in the queue.

Throws:

BrokerInvalidClientException - If the client has been destroyed or disconnected.

BrokerQueueBrowserException - If the event cannot be modified

BrokerException

deleteEvents

public int deleteEvents(long[] seqns)
                 throws BrokerException

Description copied from interface: BrokerLockedQueueBrowser

Delete events in the queue. The events are identified by their receipt sequence numbers.

Specified by:

deleteEvents in interface BrokerLockedQueueBrowser

Parameters:

seqns - An array of sequence numbers that identify the events in the queue.

Returns:

The number of events deleted from the queue.

Throws:

BrokerInvalidClientException - If the client has been destroyed or disconnected.

BrokerQueueBrowserException - If the event cannot be deleted

BrokerException

insertEventsAtHead

public void insertEventsAtHead(BrokerEvent[] events)
                        throws BrokerException

Description copied from interface: BrokerLockedQueueBrowser

Insert events in into the queue. The specified events will be inserted at the head of the queue.

Specified by:

insertEventsAtHead in interface BrokerLockedQueueBrowser

Parameters:

events - An array of events to be inserted.

Throws:

BrokerInvalidClientException - If the client has been destroyed or disconnected.

BrokerQueueBrowserException - If the event cannot be inserted

BrokerException

insertEventsAtTail

public void insertEventsAtTail(BrokerEvent[] events)
                        throws BrokerException

Description copied from interface: BrokerLockedQueueBrowser

Insert events in into the queue. The specified events will be inserted at the end of the queue.

Specified by:

insertEventsAtTail in interface BrokerLockedQueueBrowser

Parameters:

events - An array of events to be inserted.

Throws:

BrokerInvalidClientException - If the client has been destroyed or disconnected.

BrokerQueueBrowserException - If the event cannot be inserted

BrokerException

createException

protected BrokerException createException(BrokerQueueBrowserException ex)

Specified by:

createException in class BrokerQueueBrowserImpl