com.ibm.tivoli.maximo.messagehub

Class IMHProducer

java.lang.Object

com.ibm.tivoli.maximo.messagehub.IMHProducer

All Implemented Interfaces:

MessageHubProducer

public class IMHProducer
extends java.lang.Object
implements MessageHubProducer

Author:

Anamitra write messages to Kafka.

Constructor Summary

Constructors

Constructor and Description
IMHProducer(java.util.Properties producerProperties)

Method Summary

Modifier and Type	Method and Description
void	beginTX()
void	close()
void	commit()
java.util.Map<java.lang.String,java.lang.Object>	getConnectionMetaData()
void	rollback()
void	sendMessage(Message msg)

Methods inherited from class java.lang.Object

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

Constructor Detail

IMHProducer

public IMHProducer(java.util.Properties producerProperties)

Method Detail

getConnectionMetaData

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

Specified by:

getConnectionMetaData in interface MessageHubProducer

Throws:

MXException

beginTX

public void beginTX()

sendMessage

public void sendMessage(Message msg)
                 throws MXException

Specified by:

sendMessage in interface MessageHubProducer

Throws:

MXException

close

public void close()

Specified by:

close in interface MessageHubProducer

commit

public void commit()
            throws MXException

Specified by:

commit in interface MessageHubProducer

Throws:

MXException

rollback

public void rollback()
              throws MXException

Specified by:

rollback in interface MessageHubProducer

Throws:

MXException