psdi.iface.router

Class KafkaHandler

java.lang.Object

psdi.iface.router.BaseRouterHandler

psdi.iface.router.KafkaHandler

All Implemented Interfaces:

RouterHandler

public class KafkaHandler
extends BaseRouterHandler

MQHandler sends/writes data into a JMS MQ(for example : Websphere MQ). Before using this class, one must make sure that they have correct JNDI setup for Queue Connection Factory and Queue. Also depending on the JMS provider, one has to make sure that their application server classpath contains the necessessary jar files. This Class Implements RouterHandler Interface.

Version:

1.0

Author:

Anamitra

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	BOOTSTRAPSERVERS
static java.lang.String	TOPIC

Fields inherited from interface psdi.iface.router.RouterHandler

BIDICONFIG, PASSWORD, USERNAME

Constructor Summary

Constructors

Constructor and Description
KafkaHandler()
KafkaHandler(MaxEndPointInfo endPointInfo)

Method Summary

Modifier and Type	Method and Description
java.util.List<RouterPropsInfo>	getProperties()
java.lang.String	getServersString() looks for PROVIDER_URL from the Map and returns the Provider Url from the map.
java.lang.String	getTopic() looks for CON_FACTORY_JNDI_NAME from the Map and returns the Queue Connection Factory JNDI Name from the map.
java.lang.String	getUsername() The username for accessing the destination.
byte[]	invoke(java.util.Map<java.lang.String,?> metaData, byte[] data) Sends / Writes data to a given Queue.

Methods inherited from class java.lang.Object

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

Field Detail

BOOTSTRAPSERVERS

public static final java.lang.String BOOTSTRAPSERVERS

See Also:

Constant Field Values

TOPIC

public static final java.lang.String TOPIC

See Also:

Constant Field Values

Constructor Detail

KafkaHandler

public KafkaHandler(MaxEndPointInfo endPointInfo)

KafkaHandler

public KafkaHandler()

Method Detail

invoke

public byte[] invoke(java.util.Map<java.lang.String,?> metaData,
                     byte[] data)
              throws MXException

Sends / Writes data to a given Queue. This sendData method looks for two properties namely CON_FACTORY_JNDI_NAME, DEST_QUEUE_JNDI_NAME and its values for a given external system from the MAXEXTSYSHANDLER table. It uses JMSQueueProducer api to write data into a JMS Queue. Note: Before writing into Queue, if you want to compress the message(byte array), then you have to set a property called "ISCOMPRESS" = true in the MAXEXTSYSHANDLER table

Specified by:

invoke in interface RouterHandler

Overrides:

invoke in class BaseRouterHandler

Parameters:

destinationName - Name of the External System

interfaceName - interfaceName of this transacion

data - the xml transaction in byte array

Returns:

the Bidi transformed data to be collected and used by the descendant classes

Throws:

MXException - if there's a problem in writing data to queue.

See Also:

RouterHandler.invoke(java.util.Map, byte[])

getProperties

public java.util.List<RouterPropsInfo> getProperties()

Returns:

the List of supported properties.

getTopic

public java.lang.String getTopic()

looks for CON_FACTORY_JNDI_NAME from the Map and returns the Queue Connection Factory JNDI Name from the map.

Returns:

Queue Connection Factory name from the map. If there is no property in the map, it returns 'null'

getServersString

public java.lang.String getServersString()

looks for PROVIDER_URL from the Map and returns the Provider Url from the map.

Returns:

Provider URL from the map. If there is no property in the map, it returns 'null'

getUsername

public java.lang.String getUsername()

The username for accessing the destination.

Returns:

the username