org.springframework.xd.dirt.integration.bus.rabbit

Class RabbitBusCleaner

java.lang.Object

org.springframework.xd.dirt.integration.bus.rabbit.RabbitBusCleaner

All Implemented Interfaces:

BusCleaner

public class RabbitBusCleaner
extends java.lang.Object
implements BusCleaner

Implementation of BusCleaner for the RabbitMessageBus.

Since:

1.2

Author:

Gary Russell

Constructor Summary

Constructors

Constructor and Description
RabbitBusCleaner()

Method Summary

Methods

Modifier and Type	Method and Description
java.util.Map<java.lang.String,java.util.List<java.lang.String>>	clean(java.lang.String entity, boolean isJob) Clean up all resources for the supplied stream/job.
java.util.Map<java.lang.String,java.util.List<java.lang.String>>	clean(java.lang.String adminUri, java.lang.String user, java.lang.String pw, java.lang.String vhost, java.lang.String busPrefix, java.lang.String entity, boolean isJob)

Methods inherited from class java.lang.Object

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

Constructor Detail

RabbitBusCleaner

public RabbitBusCleaner()

Method Detail

clean

public java.util.Map<java.lang.String,java.util.List<java.lang.String>> clean(java.lang.String entity,
                                                                     boolean isJob)

Description copied from interface: BusCleaner

Clean up all resources for the supplied stream/job.

Specified by:

clean in interface BusCleaner

Parameters:

entity - the stream or job; may be terminated with a simple wild card '*', in which case all streams with names starting with the characters before the '*' will be cleaned.

isJob - true if the entity is a job.

Returns:

a map of lists of resources removed.

clean

public java.util.Map<java.lang.String,java.util.List<java.lang.String>> clean(java.lang.String adminUri,
                                                                     java.lang.String user,
                                                                     java.lang.String pw,
                                                                     java.lang.String vhost,
                                                                     java.lang.String busPrefix,
                                                                     java.lang.String entity,
                                                                     boolean isJob)