Package com.viglet.turing.api.queue

Class TurQueueManagementAPI

java.lang.Object

com.viglet.turing.api.queue.TurQueueManagementAPI

@RestController
@RequestMapping("/api/artemis")
public class TurQueueManagementAPI
extends Object

REST API controller for managing Artemis queues.

Author:

Alexandre Oliveira

Constructor Summary

Constructors

Constructor	Description
TurQueueManagementAPI(TurQueueManagementService queueManagementService)

Method Summary

Modifier and Type	Method	Description
org.springframework.http.ResponseEntity<Map<String,Object>>	clearQueue(String queueName)
org.springframework.http.ResponseEntity<TurQueueInfo>	getQueueInfo(String queueName)
org.springframework.http.ResponseEntity<List<TurQueueMessage>>	getQueueMessages(String queueName, int maxMessages)
org.springframework.http.ResponseEntity<List<TurQueueInfo>>	listQueues()
org.springframework.http.ResponseEntity<Map<String,Object>>	pauseQueue(String queueName)
org.springframework.http.ResponseEntity<Map<String,Object>>	resumeQueue(String queueName)
org.springframework.http.ResponseEntity<Map<String,Object>>	startQueue(String queueName)
org.springframework.http.ResponseEntity<Map<String,Object>>	stopQueue(String queueName)

Methods inherited from class java.lang.Object

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

Constructor Details

TurQueueManagementAPI

public TurQueueManagementAPI(TurQueueManagementService queueManagementService)

Method Details

listQueues

@GetMapping
public org.springframework.http.ResponseEntity<List<TurQueueInfo>> listQueues()

getQueueMessages

@GetMapping("/{queueName}/messages")
public org.springframework.http.ResponseEntity<List<TurQueueMessage>> getQueueMessages(@PathVariable
 String queueName,
 @RequestParam(defaultValue="50")
 int maxMessages)

pauseQueue

@PostMapping("/{queueName}/pause")
public org.springframework.http.ResponseEntity<Map<String,Object>> pauseQueue(@PathVariable
 String queueName)

resumeQueue

@PostMapping("/{queueName}/resume")
public org.springframework.http.ResponseEntity<Map<String,Object>> resumeQueue(@PathVariable
 String queueName)

startQueue

@PostMapping("/{queueName}/start")
public org.springframework.http.ResponseEntity<Map<String,Object>> startQueue(@PathVariable
 String queueName)

stopQueue

@PostMapping("/{queueName}/stop")
public org.springframework.http.ResponseEntity<Map<String,Object>> stopQueue(@PathVariable
 String queueName)

clearQueue

@DeleteMapping("/{queueName}/messages")
public org.springframework.http.ResponseEntity<Map<String,Object>> clearQueue(@PathVariable
 String queueName)

getQueueInfo

@GetMapping("/{queueName}")
public org.springframework.http.ResponseEntity<TurQueueInfo> getQueueInfo(@PathVariable
 String queueName)