com.atlassian.crowd.plugins.testkit.rest

Class TestkitClusterMessagingResource

java.lang.Object

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

@Named
 @Path(value="/messaging")
 @Produces(value="application/json")
 @Consumes(value="application/json")
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

@Path(value="/view")
 @GET
public javax.ws.rs.core.Response viewStoredMessages()
                                                                        throws IOException

Throws:

IOException

viewAllRawMessages

@Path(value="/raw")
 @GET
public javax.ws.rs.core.Response viewAllRawMessages()
                                                                       throws IOException

Throws:

IOException

reset

@Path(value="/reset")
 @POST
public javax.ws.rs.core.Response reset()

publish

@Path(value="/publish/{channel}/{message}")
 @POST
public javax.ws.rs.core.Response publish(@PathParam(value="channel")
                                                                                            String channel,
                                                                                            @PathParam(value="message")
                                                                                            String message)

listenOnChannel

@Path(value="/listen/{channel}")
 @POST
public javax.ws.rs.core.Response listenOnChannel(@PathParam(value="channel")
                                                                                         String channel)

changeSchedulerState

@Path(value="/state/{value}")
 @POST
public javax.ws.rs.core.Response changeSchedulerState(@PathParam(value="value")
                                                                                           String state)

reapOldMessages

@Path(value="/reap/{offset}")
 @POST
public javax.ws.rs.core.Response reapOldMessages(@PathParam(value="offset")
                                                                                      long offset)