Examples of com.streamreduce.OutboundStorageException

com.streamreduce.OutboundStorageException
Exception that occurs when an attempt to store a payload via the Outbound Message Gateway fails. Instances of this Exception should signal failure and trigger some form of retry to the outbound storage, but should not terminate the execution path of logic that triggered persisting to the Outbound Message Gateway.

        try {
            String key = createInsightMessagePath(sobaMessage);
            byte[] payload = convertSobaMessageToDTOAsBytes(sobaMessage);
            sendPayload(key,payload);
        } catch (Exception e) {
            throw new OutboundStorageException(e.getMessage(), e);
        }
    }

View Full Code Here

            String result = awsClient.pushToS3(outboundConfiguration, key, payload);
            if (LOGGER.isDebugEnabled()) {
                LOGGER.debug("rawMessage sent to S3 identified by: " + result);
            }
        } catch (Exception e) {
            throw new OutboundStorageException(e.getMessage(), e);
        }
    }

View Full Code Here

    public int sendSobaMessage(SobaMessage sobaMessage) throws OutboundStorageException {
        try {
            Connection c = connectionService.getConnection(sobaMessage.getConnectionId());
            return sendSobaMessage(sobaMessage, c);
        } catch (ConnectionNotFoundException e) {
            throw new OutboundStorageException("Unable to retrieve Connection for sobaMessage with Id of "
                    + sobaMessage.getId(), e);
        }
    }

View Full Code Here

0 1

TOP

Related Classes of com.streamreduce.OutboundStorageException

com.streamreduce.client.outbound.S3OutboundClient

com.streamreduce.client.outbound.WebHDFSOutboundClient

com.streamreduce.core.component.OutboundMessageProcessor

com.streamreduce.core.service.OutboundStorageServiceImpl

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.