RedisReceiver is a JMS message producer that block-pops items from a given Redis list or subscribes messages from a given Redis channel. It puts the content to JMS messages. Those messages will be sent to an XQueue as the output. RedisReceiver supports flow control and allows object control from its owner. It is fault tolerant with retry and idle options.
Apart from the common properties, there are many implementation specific properties for RedisReceiver.
Property Name | Data Type | Requirement | Description | Examples |
---|---|---|---|---|
DefaultKeyName | string | required | the name of channel or the list | mylist |
Currently, RedisReceiver only supports two operations, get and sub.
Here is an example of RedisReceiver:
{ "Name": "rcvr_redis", "ClassName": "org.qbroker.receiver.RedisReceiver", "URI": "redis://localhost:6379", "LinkName": "root", "Partition": "0,0", "Operation": "sub", "DefaultKeyName": "ch1", "Mode": "daemon", "XAMode": "0", "TextMode": "1", "DisplayMask": "0" }where it subscribes to the channel of ch1.