org.springframework.xd.dirt.integration.bus

Class BusUtils

java.lang.Object

org.springframework.xd.dirt.integration.bus.BusUtils

public class BusUtils
extends java.lang.Object

Message Bus utilities.

Author:

Gary Russell

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	GROUP_INDEX_DELIMITER The delimiter between a group and index when constructing a bus consumer/producer.
static java.util.regex.Pattern	PUBSUB_NAMED_CHANNEL_PATTERN
static java.lang.String	TAP_CHANNEL_PREFIX The prefix for the consumer/producer when creating a tap.
static java.lang.String	TOPIC_CHANNEL_PREFIX The prefix for the consumer/producer when creating a topic.

Constructor Summary

Constructors

Constructor and Description
BusUtils()

Method Summary

Methods

Modifier and Type	Method and Description
static java.lang.String	addGroupToPubSub(java.lang.String group, java.lang.String inputChannelName)
static java.lang.String	constructPipeName(java.lang.String group, int index) Construct a pipe name from the group and index.
static java.lang.String	constructTapPrefix(java.lang.String group)
static java.lang.String	getGroupFromPubSub(java.lang.String name)
static boolean	isChannelPubSub(java.lang.String channelName) Determine whether the provided channel name represents a pub/sub channel (i.e.
static java.lang.String	removeGroupFromPubSub(java.lang.String name)

Methods inherited from class java.lang.Object

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

Field Detail

GROUP_INDEX_DELIMITER

public static final java.lang.String GROUP_INDEX_DELIMITER

The delimiter between a group and index when constructing a bus consumer/producer.

See Also:

Constant Field Values

TAP_CHANNEL_PREFIX

public static final java.lang.String TAP_CHANNEL_PREFIX

The prefix for the consumer/producer when creating a tap.

See Also:

Constant Field Values

TOPIC_CHANNEL_PREFIX

public static final java.lang.String TOPIC_CHANNEL_PREFIX

The prefix for the consumer/producer when creating a topic.

See Also:

Constant Field Values

PUBSUB_NAMED_CHANNEL_PATTERN

public static final java.util.regex.Pattern PUBSUB_NAMED_CHANNEL_PATTERN

Constructor Detail

BusUtils

public BusUtils()

Method Detail

addGroupToPubSub

public static java.lang.String addGroupToPubSub(java.lang.String group,
                                java.lang.String inputChannelName)

removeGroupFromPubSub

public static java.lang.String removeGroupFromPubSub(java.lang.String name)

getGroupFromPubSub

public static java.lang.String getGroupFromPubSub(java.lang.String name)

isChannelPubSub

public static boolean isChannelPubSub(java.lang.String channelName)

Determine whether the provided channel name represents a pub/sub channel (i.e. topic or tap).

Parameters:

channelName - name of the channel to check

Returns:

true if pub/sub.

constructPipeName

public static java.lang.String constructPipeName(java.lang.String group,
                                 int index)

Construct a pipe name from the group and index.

Parameters:

group - the group.

index - the index.

Returns:

the name.

constructTapPrefix

public static java.lang.String constructTapPrefix(java.lang.String group)