com.atlassian.crowd.plugins.testkit.rest

Class TestkitClusterMessagingResource

java.lang.Object

com.atlassian.crowd.plugins.testkit.rest.TestkitClusterMessagingResource

@Named
public class TestkitClusterMessagingResource
extends Object

Constructor Summary

Constructors

Constructor and Description
TestkitClusterMessagingResource(ClusterMessageService clusterMessageService, ClusterMessageManager clusterMessageManager)

Method Summary

Modifier and Type	Method and Description
javax.ws.rs.core.Response	changeSchedulerState(String state)
javax.ws.rs.core.Response	listenOnChannel(String channel)
javax.ws.rs.core.Response	publish(String channel, String message)
javax.ws.rs.core.Response	reapOldMessages(long offset)
javax.ws.rs.core.Response	reset()
javax.ws.rs.core.Response	viewAllRawMessages()
javax.ws.rs.core.Response	viewStoredMessages()

Methods inherited from class java.lang.Object

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

Constructor Detail

TestkitClusterMessagingResource

@Inject
public TestkitClusterMessagingResource(ClusterMessageService clusterMessageService,
                                               ClusterMessageManager clusterMessageManager)

Method Detail

viewStoredMessages

public javax.ws.rs.core.Response viewStoredMessages()
                                             throws IOException

Throws:

IOException

viewAllRawMessages

public javax.ws.rs.core.Response viewAllRawMessages()
                                             throws IOException

Throws:

IOException

reset

public javax.ws.rs.core.Response reset()

publish

public javax.ws.rs.core.Response publish(String channel,
                                         String message)

listenOnChannel

public javax.ws.rs.core.Response listenOnChannel(String channel)

changeSchedulerState

public javax.ws.rs.core.Response changeSchedulerState(String state)

reapOldMessages

public javax.ws.rs.core.Response reapOldMessages(long offset)