Skip to content
Data > Feed Handlers

TIBCO EMS

Message Format

This feedhandler only accepts JSON protobuf messages as an input source and expects the message to be in a single map where each key represents a column on a table and its value a single column value.

Sample valid JSON message:

1
2
3
4
5
{
  "colA": "colAValue",
  "colB": 123,
  ...
}

Note that by default, all column types are inferred to be Strings unless explicitly defined In the ami.relay.fh.tibcoems.props.tableMappingproperty using a colName=colType,... syntax.

Null values in the JSON message are skipped.

Valid types are as follows:

Underlying Column Type Valid Property Name (Case Insensitive)
String str, string
Integer int, integer
Short short
Long long
Float float
Double double
Character char, character
Boolean bool, boolean

Properties

Required

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
# Use this to configure one or more FHs
ami.relay.fh.active=tibcoems

# Used to start the FH
ami.relay.fh.tibcoems.start=true

# Must match exactly
ami.relay.fh.tibcoems.class=com.f1.ami.relay.fh.tibcoems.AmiTibcoEMSFH

# Name of AMI table for data to be streamed into
ami.relay.fh.tibcoems.props.tableName=tableName

# Client id to be used
ami.relay.fh.tibcoems.props.clientID=id

# Specifies the host address of the tibco ems instance
ami.relay.fh.tibcoems.props.serverUrl=localhost:1234

# Specifies the username to be used
ami.relay.fh.tibcoems.props.username=username

# Specifies the password to be used
ami.relay.fh.tibcoems.props.password=password

# Specifies a topic or queue to subscribe to, one or the other must be specified
ami.relay.fh.tibcoems.props.topic=topicName
ami.relay.fh.tibcoems.props.queue=queueName

Optional

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
# Specify column name and its underlying types
ami.relay.fh.tibcoems.props.tableMapping=colA=String,colB=int

# Specifies if the JNDI protocol should be used for the connection, defaults to false
ami.relay.fh.tibcoems.props.useJNDI=true/false

# If using the JNDI protocol, should TLS be used, defaults to false
ami.relay.fh.tibcoems.props.useTLS=true/false

# Specifies if/how messages should be acknowledged. Valid inputs are: auto,client,dups_ok,explicit_client,explicit_client_dups_ok,no. Defaults to auto
ami.relay.fh.tibcoems.props.ackMode=auto