Package com.rabbitmq.client

Class StringRpcServer

java.lang.Object

com.rabbitmq.client.RpcServer

com.rabbitmq.client.StringRpcServer

Direct Known Subclasses:

JsonRpcServer

public class StringRpcServer
extends RpcServer

Subclass of RpcServer which accepts UTF-8 string requests.

Nested Class Summary

Nested classes/interfaces inherited from class com.rabbitmq.client.RpcServer

RpcServer.RpcConsumer

Field Summary

Fields

Modifier and Type	Field	Description
static final String	STRING_ENCODING

Constructor Summary

Constructors

Constructor	Description
StringRpcServer(Channel channel)
StringRpcServer(Channel channel, String queueName)

Method Summary

Modifier and Type	Method	Description
byte[]	handleCall(byte[] requestBody, AMQP.BasicProperties replyProperties)	Overridden to do UTF-8 processing, and delegate to handleStringCall.
void	handleCast(byte[] requestBody)	Overridden to do UTF-8 processing, and delegate to handleStringCast.
String	handleStringCall(String request)	Default implementation - override in subclasses.
String	handleStringCall(String request, AMQP.BasicProperties replyProperties)	Delegates to handleStringCall(String).
void	handleStringCast(String requestBody)	Default implementation - override in subclasses.

Methods inherited from class com.rabbitmq.client.RpcServer

close, getChannel, getQueueName, handleCall, handleCall, handleCast, handleCast, mainloop, postprocessReplyProperties, preprocessReplyProperties, processRequest, setupConsumer, terminateMainloop

Methods inherited from class java.lang.Object

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

Field Details

STRING_ENCODING

public static final String STRING_ENCODING

See Also:

• Constant Field Values

Constructor Details

StringRpcServer

public StringRpcServer(Channel channel)
                throws IOException

Throws:

IOException

StringRpcServer

public StringRpcServer(Channel channel,
 String queueName)
                throws IOException

Throws:

IOException

Method Details

handleCall

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

Overridden to do UTF-8 processing, and delegate to handleStringCall. If UTF-8 is not understood by this JVM, falls back to the platform default.

Overrides:

handleCall in class RpcServer

handleStringCall

public String handleStringCall(String request,
 AMQP.BasicProperties replyProperties)

Delegates to handleStringCall(String).

handleStringCall

public String handleStringCall(String request)

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

handleCast

public void handleCast(byte[] requestBody)

Overridden to do UTF-8 processing, and delegate to handleStringCast. If requestBody cannot be interpreted as UTF-8 tries the platform default.

Overrides:

handleCast in class RpcServer

handleStringCast

public void handleStringCast(String requestBody)

Default implementation - override in subclasses. Does nothing.