com.ibm.tivoli.maximo.messagehub

Class IMHBrowser

java.lang.Object

com.ibm.tivoli.maximo.messagehub.IMHBrowser

All Implemented Interfaces:

MessageHubBrowser

public class IMHBrowser
extends java.lang.Object
implements MessageHubBrowser

Field Summary

Fields

Modifier and Type	Field and Description
protected static MXLogger	integrationLogger

Constructor Summary

Constructors

Constructor and Description
IMHBrowser(java.util.Properties consumerProperties)

Method Summary

Modifier and Type	Method and Description
java.util.List	browseMessages(long maxCount, long skipCount, long fromOffset)
void	close()
java.util.Map	getConnectionMetaData()
static void	main(java.lang.String[] args)
java.lang.Long	position(int partition)
void	seek(int partition, long offset)

Methods inherited from class java.lang.Object

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

Field Detail

integrationLogger

protected static final MXLogger integrationLogger

Constructor Detail

IMHBrowser

public IMHBrowser(java.util.Properties consumerProperties)

Method Detail

close

public void close()
           throws MXException

Specified by:

close in interface MessageHubBrowser

Throws:

MXException

getConnectionMetaData

public java.util.Map getConnectionMetaData()
                                    throws MXException

Specified by:

getConnectionMetaData in interface MessageHubBrowser

Throws:

MXException

position

public java.lang.Long position(int partition)

seek

public void seek(int partition,
                 long offset)

main

public static void main(java.lang.String[] args)
                 throws java.io.UnsupportedEncodingException,
                        java.lang.InterruptedException,
                        java.util.concurrent.ExecutionException,
                        java.util.concurrent.TimeoutException

Throws:

java.io.UnsupportedEncodingException

java.lang.InterruptedException

java.util.concurrent.ExecutionException

java.util.concurrent.TimeoutException

browseMessages

public java.util.List browseMessages(long maxCount,
                                     long skipCount,
                                     long fromOffset)
                              throws MXException

Specified by:

browseMessages in interface MessageHubBrowser

Throws:

MXException