org.springframework.cloud.stream.binder

Class DefaultBinding<T>

java.lang.Object

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

All Implemented Interfaces:

Binding<T>, org.springframework.context.Lifecycle, org.springframework.integration.endpoint.Pausable

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

Default implementation for a Binding.

Author:

Jennifer Hickey, Mark Fisher, Gary Russell, Marius Bogoevici, Oleg Zhurakousky

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() Returns the name of this binding (i.e., channel name)
String	getState()
boolean	isPausable()
boolean	isRunning() Returns 'true' if the target component represented by this instance is running.
void	pause() Pauses the target component represented by this instance if and only if the component implements Pausable interface NOTE: At the time the instance is created the component is already started and active.
void	resume() Resumes the target component represented by this instance if and only if the component implements Pausable interface NOTE: At the time the instance is created the component is already started and active.
void	start() Stops the target component represented by this instance.
void	stop() Starts the target component represented by this instance.
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

Methods inherited from interface org.springframework.cloud.stream.binder.Binding

getExtendedInfo

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()

Description copied from interface: Binding

Returns the name of this binding (i.e., channel name)

Specified by:

getName in interface Binding<T>

Returns:

binding name

getGroup

public String getGroup()

getState

public String getState()

isRunning

public boolean isRunning()

Description copied from interface: Binding

Returns 'true' if the target component represented by this instance is running.

Specified by:

isRunning in interface Binding<T>

Specified by:

isRunning in interface org.springframework.context.Lifecycle

isPausable

public boolean isPausable()

start

public final void start()

Description copied from interface: Binding

Stops the target component represented by this instance. NOTE: At the time the instance is created the component is already started. This operation is typically used by actuator to re-bind/re-start.

Specified by:

start in interface Binding<T>

Specified by:

start in interface org.springframework.context.Lifecycle

See Also:

BindingsEndpoint

stop

public final void stop()

Description copied from interface: Binding

Starts the target component represented by this instance. NOTE: At the time the instance is created the component is already started. This operation is typically used by actuator to re-bind/re-start.

Specified by:

stop in interface Binding<T>

Specified by:

stop in interface org.springframework.context.Lifecycle

See Also:

BindingsEndpoint

pause

public final void pause()

Description copied from interface: Binding

Pauses the target component represented by this instance if and only if the component implements Pausable interface NOTE: At the time the instance is created the component is already started and active. This operation is typically used by actuator to pause/resume.

Specified by:

pause in interface Binding<T>

Specified by:

pause in interface org.springframework.integration.endpoint.Pausable

See Also:

BindingsEndpoint

resume

public final void resume()

Description copied from interface: Binding

Resumes the target component represented by this instance if and only if the component implements Pausable interface NOTE: At the time the instance is created the component is already started and active. This operation is typically used by actuator to pause/resume.

Specified by:

resume in interface Binding<T>

Specified by:

resume in interface org.springframework.integration.endpoint.Pausable

See Also:

BindingsEndpoint

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>

toString

public String toString()

Overrides:

toString in class Object

afterUnbind

protected void afterUnbind()

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