public class

MapRpcServer

extends RpcServer
java.lang.Object
   ↳ com.rabbitmq.client.RpcServer
     ↳ com.rabbitmq.client.MapRpcServer

Class Overview

Subclass of RpcServer which uses AMQP wire-format encoded tables as requests and replies.

Summary

Public Constructors
MapRpcServer(Channel channel)
MapRpcServer(Channel channel, String queueName)
Public Methods
static Map<String, Object> decode(byte[] requestBody)
static byte[] encode(Map<String, Object> reply)
byte[] handleCall(byte[] requestBody, AMQP.BasicProperties replyProperties)
Overridden to delegate to handleMapCall.
void handleCast(byte[] requestBody)
Overridden to delegate to handleMapCast.
Map<String, Object> handleMapCall(Map<String, Object> request)
Default implementation - override in subclasses.
Map<String, Object> handleMapCall(Map<String, Object> request, AMQP.BasicProperties replyProperties)
Delegates to handleMapCall(Map).
void handleMapCast(Map<String, Object> requestBody)
Default implementation - override in subclasses.
[Expand]
Inherited Methods
From class com.rabbitmq.client.RpcServer
From class java.lang.Object

Public Constructors

public MapRpcServer (Channel channel)

Throws
IOException

public MapRpcServer (Channel channel, String queueName)

Throws
IOException

Public Methods

public static Map<String, Object> decode (byte[] requestBody)

Throws
IOException

public static byte[] encode (Map<String, Object> reply)

Throws
IOException

public byte[] handleCall (byte[] requestBody, AMQP.BasicProperties replyProperties)

Overridden to delegate to handleMapCall.

public void handleCast (byte[] requestBody)

Overridden to delegate to handleMapCast.

public Map<String, Object> handleMapCall (Map<String, Object> request)

Default implementation - override in subclasses. Returns the empty string.

public Map<String, Object> handleMapCall (Map<String, Object> request, AMQP.BasicProperties replyProperties)

Delegates to handleMapCall(Map).

public void handleMapCast (Map<String, Object> requestBody)

Default implementation - override in subclasses. Does nothing.