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

Author:

pshukla1 Consumes messages from the Kafka.

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
java.util.List<Message>	browseMessages(long maxCount, long skipCount)
void	close()
java.util.Map<java.lang.String,java.lang.Object>	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

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

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<java.lang.String,java.lang.Object> 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<Message> browseMessages(long maxCount,
                                              long skipCount)
                                       throws MXException

Specified by:

browseMessages in interface MessageHubBrowser

Throws:

MXException