com.ibm.tivoli.maximo.messagehub

Class IMHConsumer

java.lang.Object

com.ibm.tivoli.maximo.messagehub.IMHConsumer

All Implemented Interfaces:

MessageHubConsumer

public class IMHConsumer
extends java.lang.Object
implements MessageHubConsumer

Author:

pshukla1,Anamitra Consumes messages from the Kafka.

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	close()
void	commit()
void	commit(java.util.Map md)
java.util.Map<java.lang.String,java.lang.Object>	getConnectionMetaData()
Message	getMessage()
java.util.List<Message>	getMessages()
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

IMHConsumer

public IMHConsumer(java.util.Properties consumerProperties)

Method Detail

commit

public void commit()
            throws MXException

Specified by:

commit in interface MessageHubConsumer

Throws:

MXException

commit

public void commit(java.util.Map md)
            throws MXException

Specified by:

commit in interface MessageHubConsumer

Throws:

MXException

close

public void close()

Specified by:

close in interface MessageHubConsumer

getMessages

public java.util.List<Message> getMessages()
                                    throws MXException

Specified by:

getMessages in interface MessageHubConsumer

Throws:

MXException

getMessage

public Message getMessage()
                   throws MXException

Throws:

MXException

getConnectionMetaData

public java.util.Map<java.lang.String,java.lang.Object> getConnectionMetaData()
                                                                       throws MXException

Specified by:

getConnectionMetaData in interface MessageHubConsumer

Throws:

MXException

position

public java.lang.Long position(int partition)

seek

public void seek(int partition,
                 long offset)