org.springframework.cloud.stream.binder

Class DefaultBinding<T>

java.lang.Object

org.springframework.cloud.stream.binder.DefaultBinding<T>

All Implemented Interfaces:

Binding<T>

public class DefaultBinding<T>
extends Object
implements Binding<T>

Default implementation for a Binding.

Author:

Jennifer Hickey, Mark Fisher, Gary Russell, Marius Bogoevici

See Also:

EnableBinding

Field Summary

Fields

Modifier and Type	Field and Description
protected String	group
protected org.springframework.context.Lifecycle	lifecycle
protected String	name
protected T	target

Constructor Summary

Constructors

Constructor and Description
DefaultBinding(String name, String group, T target, org.springframework.context.Lifecycle lifecycle) Creates an instance that associates a given name, group and binding target with an optional Lifecycle component, which will be stopped during unbinding.

Method Summary

Modifier and Type	Method and Description
protected void	afterUnbind() Listener method that executes after unbinding.
String	getGroup()
String	getName()
String	toString()
void	unbind() Unbinds the target component represented by this instance and stops any active components.

Methods inherited from class java.lang.Object

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

Field Detail

name

protected final String name

group

protected final String group

target

protected final T target

lifecycle

protected final org.springframework.context.Lifecycle lifecycle

Constructor Detail

DefaultBinding

public DefaultBinding(String name,
                      String group,
                      T target,
                      org.springframework.context.Lifecycle lifecycle)

Creates an instance that associates a given name, group and binding target with an optional Lifecycle component, which will be stopped during unbinding.

Parameters:

name - the name of the binding target

group - the group (only for input targets)

target - the binding target

lifecycle - Lifecycle that runs while the binding is active and will be stopped during unbinding

Method Detail

getName

public String getName()

getGroup

public String getGroup()

unbind

public final void unbind()

Description copied from interface: Binding

Unbinds the target component represented by this instance and stops any active components. Implementations must be idempotent. After this method is invoked, the target is not expected to receive any messages; this instance should be discarded, and a new Binding should be created instead.

Specified by:

unbind in interface Binding<T>

afterUnbind

protected void afterUnbind()

Listener method that executes after unbinding. Subclasses can implement their own behaviour on unbinding by overriding this method.

toString

public String toString()

Overrides:

toString in class Object