Skip to content

Commit f146c8f

Browse files
Naming
"preprocess" and "postprocess" are perfectly fine verbs ;)
1 parent e04b7a1 commit f146c8f

File tree

2 files changed

+6
-6
lines changed

2 files changed

+6
-6
lines changed

src/main/java/com/rabbitmq/client/RpcServer.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -146,9 +146,9 @@ public void processRequest(QueueingConsumer.Delivery request)
146146
{
147147
AMQP.BasicProperties.Builder replyPropertiesBuilder
148148
= new AMQP.BasicProperties.Builder().correlationId(correlationId);
149-
AMQP.BasicProperties replyProperties = preProcessReplyProperties(request, replyPropertiesBuilder);
149+
AMQP.BasicProperties replyProperties = preprocessReplyProperties(request, replyPropertiesBuilder);
150150
byte[] replyBody = handleCall(request, replyProperties);
151-
replyProperties = postProcessReplyProperties(request, replyProperties.builder());
151+
replyProperties = postprocessReplyProperties(request, replyProperties.builder());
152152
_channel.basicPublish("", replyTo, replyProperties, replyBody);
153153
} else {
154154
handleCast(request);
@@ -196,7 +196,7 @@ public byte[] handleCall(byte[] requestBody,
196196
* @param builder the reply properties builder
197197
* @return the properties to pass in to the handling call
198198
*/
199-
protected AMQP.BasicProperties preProcessReplyProperties(QueueingConsumer.Delivery request, AMQP.BasicProperties.Builder builder) {
199+
protected AMQP.BasicProperties preprocessReplyProperties(QueueingConsumer.Delivery request, AMQP.BasicProperties.Builder builder) {
200200
return builder.build();
201201
}
202202

@@ -206,7 +206,7 @@ protected AMQP.BasicProperties preProcessReplyProperties(QueueingConsumer.Delive
206206
* @param builder the reply properties builder
207207
* @return the properties to pass in to the response message
208208
*/
209-
protected AMQP.BasicProperties postProcessReplyProperties(QueueingConsumer.Delivery request, AMQP.BasicProperties.Builder builder) {
209+
protected AMQP.BasicProperties postprocessReplyProperties(QueueingConsumer.Delivery request, AMQP.BasicProperties.Builder builder) {
210210
return builder.build();
211211
}
212212

src/test/java/com/rabbitmq/client/test/RpcTest.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -84,7 +84,7 @@ public TestRpcServer(Channel channel, String queueName) throws IOException {
8484
}
8585

8686
@Override
87-
protected AMQP.BasicProperties preProcessReplyProperties(QueueingConsumer.Delivery request, AMQP.BasicProperties.Builder builder) {
87+
protected AMQP.BasicProperties preprocessReplyProperties(QueueingConsumer.Delivery request, AMQP.BasicProperties.Builder builder) {
8888
Map<String, Object> headers = new HashMap<String, Object>();
8989
headers.put("pre", "pre-" + new String(request.getBody()));
9090
builder.headers(headers);
@@ -98,7 +98,7 @@ public byte[] handleCall(QueueingConsumer.Delivery request, AMQP.BasicProperties
9898
}
9999

100100
@Override
101-
protected AMQP.BasicProperties postProcessReplyProperties(QueueingConsumer.Delivery request, AMQP.BasicProperties.Builder builder) {
101+
protected AMQP.BasicProperties postprocessReplyProperties(QueueingConsumer.Delivery request, AMQP.BasicProperties.Builder builder) {
102102
Map<String, Object> headers = new HashMap<String, Object>(builder.build().getHeaders());
103103
headers.put("post", "post-" + new String(request.getBody()));
104104
builder.headers(headers);

0 commit comments

Comments
 (0)