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

Field Summary

Fields

Modifier and Type	Field and Description
protected static MXLogger	integrationLogger

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	getConnectionMetaData()
Message	getMessage()
java.util.List	getMessages()
boolean	isValid()
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

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 getMessages()
                           throws MXException

Specified by:

getMessages in interface MessageHubConsumer

Throws:

MXException

getMessage

public Message getMessage()
                   throws MXException

Throws:

MXException

getConnectionMetaData

public java.util.Map 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)

isValid

public boolean isValid()

Specified by:

isValid in interface MessageHubConsumer