JMS Custom Input Adapter

Adapter type: jms_custom_in. The JMS Custom Input adapter subscribes to custom-formatted Java object messages from a JMS queue or topic, and writes them as stream records.

A custom-provided implementation performs the format conversions of this interface:

package com.sybase.esp.adapters;
public interface ExternalToESPConverter {
	public ESPMessage externalToESP(Serializable externalMessage) throws Exception;
}

Ensure that the objects returned by the externalToESP method implement this interface:

package com.sybase.esp.adapters;
public interface ESPMessage extends Serializable {
	public String getStreamName();
	public String getOpCode();
	public Map<String, Serializable> getColumnValues();
}

The objects returned by the getStreamName, getOpCode, getColumnValues methods are interpreted as the name of the stream to write to, the opcode, and the stream record as a column to message property map value.

Ensure that stream column types correspond to Java classes as follows:

Stream Column Type	Java Class
`bigdatetime`	`java.lang.Double`
`binary`	`java.lang.String`
`boolean`	`java.lang.Boolean`
`integer`	`java.lang.Integer`
`interval`	`java.lang.Long`
`date`	`java.util.Date`
`float`	`java.lang.Double`
`long`	`java.lang.Long`
`money1`	`java.math.BigDecimal`
`money2`	`java.math.BigDecimal`
`money3`	`java.math.BigDecimal`
`money4`	`java.math.BigDecimal`
`money5`	`java.math.BigDecimal`
`money6`	`java.math.BigDecimal`
`money7`	`java.math.BigDecimal`
`money8`	`java.math.BigDecimal`
`money9`	`java.math.BigDecimal`
`money10`	`java.math.BigDecimal`
`money11`	`java.math.BigDecimal`
`money12`	`java.math.BigDecimal`
`money13`	`java.math.BigDecimal`
`money14`	`java.math.BigDecimal`
`money15`	`java.math.BigDecimal`
`string`	`java.lang.String`
`timestamp`	`java.util.Date`

Ensure that implementations of the ExternalToEFSConverter interface provide a constructor with a single argument of java.lang.String type, or a default constructor with no arguments.

Note: Records with unmatched stream names are ignored. Records with null opcodes are interpreted as upserts. The values of non-key columns may be absent or null.

If an implementation is not provided, the default implementation is used, which interprets each external message as an instance of the DefaultEFSMessage class and does not perform a conversion.

Ensure that a Java archive containing an implementation of the ExternalToEFSConverter interface is provided, and place it in the lib subfolder of the Event Stream Processor installation folder.

If you use the CCL ATTACH ADAPTER statement to attach an adapter, you must supply the adapter type.

Note: This adapter supports schema discovery.

Property Label	Property ID	Type	Description
Converter Class Name	converterClassName	`string`	(Required) External to ESP message converter fully qualified class name. No default value.
Connection Factory	connectionFactory	`string`	(Required) Connection factory class name. No default value.
JNDI Context Factory	jndiContextFactory	`string`	(Required) Context factory for JNDI context initialization. No default value.
JNDI URL	jndiURL	`string`	(Required) JNDI URL. No default value.
Destination Type	destinationType	`choice`	(Required) Destination type. Valid values are: QUEUE TOPIC Default value is QUEUE.
Destination Name	destinationName	`string`	(Required) Destination name. No default value.
Converter Parameter	converterParam	`string`	(Optional) External to Event Stream Processor message converter start-up parameter. No default value.
Subscription Mode	subscriptionMode	`choice`	(Optional) Specifies the subscription mode for TOPIC. Default value is NONDURABLE. Valid values are DURABLE and NONDURABLE.
Client ID	clientID	`string`	(Optional) Specifies the client identifier for the connection that is identifying durable subscription. No default value.
Subscription Name	subscriptionName	`string`	(Optional) Specifies a unique name identifying a durable subscription. No default value.
Batch Size	batchsize	`uint`	(Optional) Specifies number of records in a batch to commit in durable subscription mode. Default value is 1.
PropertySet	propertyset	`string`	(Advanced) Specifies the name of the property set from the project configuration file. If you specify the same properties in the project configuration file and the ATTACH ADAPTER statement, the values in the property set override the values defined in the ATTACH ADAPTER statement. No default value.
Date Format	dateFormat	`string`	(Advanced) Date format. Default value is YYYY-MM-DDTHH:MM:SS.SSS.
Timestamp Format	timestampFormat	`string`	(Advanced) Timestamp format. Default value is YYYY-MM-DDTHH:MM:SS.SSS.

Known limitations:

If the connection to the message broker is lost, the adapter does not attempt to reconnect.