Skip to content

Commit bc7df3d

Browse files
authored
Parse email response as a byte array (#10)
1 parent fb9c897 commit bc7df3d

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

apps/contoso-fiber/src/main/java/com/contoso/cams/support/SupportGuideEmailResponseProcessor.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -26,7 +26,7 @@ public class SupportGuideEmailResponseProcessor {
2626
private final SupportCaseService supportCaseService;
2727

2828
@Bean
29-
Consumer<Message<String>> consumeemailresponse() {
29+
Consumer<Message<byte[]>> consumeemailresponse() {
3030
return message -> {
3131
Checkpointer checkpointer = (Checkpointer) message.getHeaders().get(CHECKPOINTER);
3232
log.info("Received message: {}", message.getPayload());
@@ -49,9 +49,9 @@ Consumer<Message<String>> consumeemailresponse() {
4949
};
5050
}
5151

52-
private EmailResponse parseMessage(Message<String> message) {
52+
private EmailResponse parseMessage(Message<byte[]> message) {
5353
try {
54-
EmailResponse emailResponse = EmailResponse.parseFrom(message.getPayload().getBytes());
54+
EmailResponse emailResponse = EmailResponse.parseFrom(message.getPayload());
5555
return emailResponse;
5656
} catch (InvalidProtocolBufferException e) {
5757
log.error("Error parsing email request message", e);

0 commit comments

Comments
 (0)