private void sendPubSubMessage()

in src/main/java/com/google/gcs/sdrs/service/mq/PubSubMessageQueueManagerImpl.java [166:191]

23 lines of code
1 McCabe index (conditional complexity)


  private void sendPubSubMessage(ByteString data) {
    PubsubMessage pubsubMessage = PubsubMessage.newBuilder().setData(data).build();

    ApiFuture<String> future = publisher.publish(pubsubMessage);
    ApiFutures.addCallback(
        future,
        new ApiFutureCallback<String>() {

          @Override
          public void onFailure(Throwable throwable) {
            logger.error(
                String.format(
                    "Error publishing message: %s %s",
                    new String(data.toByteArray()), throwable.getMessage()));
          }

          @Override
          public void onSuccess(String messageId) {
            logger.info(
                String.format(
                    "Successfully sending message id: %s  message: %s",
                    messageId, new String(data.toByteArray())));
          }
        },
        MoreExecutors.directExecutor());
  }