public abstract Stream<ChampObject> queryObjects(Map<String, Object> queryParams);
public abstract ChampRelationship executeStoreRelationship(ChampRelationship relationship) throws ChampUnmarshallingException, ChampMarshallingException, ChampObjectNotExistsException, ChampSchemaViolationException, ChampRelationshipNotExistsException;
public abstract ChampRelationship executeReplaceRelationship(ChampRelationship relationship) throws ChampUnmarshallingException, ChampMarshallingException, ChampSchemaViolationException, ChampRelationshipNotExistsException;
+ @Override
public abstract Optional<ChampRelationship> retrieveRelationship(Object key) throws ChampUnmarshallingException;
public abstract void executeDeleteRelationship(ChampRelationship relationship) throws ChampRelationshipNotExistsException;
+ @Override
public abstract Stream<ChampRelationship> retrieveRelationships(ChampObject object) throws ChampUnmarshallingException, ChampObjectNotExistsException;
+ @Override
public abstract Stream<ChampRelationship> queryRelationships(Map<String, Object> queryParams);
public abstract ChampPartition executeStorePartition(ChampPartition partition) throws ChampSchemaViolationException, ChampRelationshipNotExistsException, ChampMarshallingException, ChampObjectNotExistsException;
public abstract void executeDeletePartition(ChampPartition graph);
public abstract void executeStoreObjectIndex(ChampObjectIndex index);
+ @Override
public abstract Optional<ChampObjectIndex> retrieveObjectIndex(String indexName);
+ @Override
public abstract Stream<ChampObjectIndex> retrieveObjectIndices();
public abstract void executeDeleteObjectIndex(String indexName) throws ChampIndexNotExistsException;
public abstract void executeStoreRelationshipIndex(ChampRelationshipIndex index);
+ @Override
public abstract Optional<ChampRelationshipIndex> retrieveRelationshipIndex(String indexName);
public abstract Stream<ChampRelationshipIndex> retrieveRelationshipIndices();
public abstract void executeDeleteRelationshipIndex(String indexName) throws ChampIndexNotExistsException;
/** Configuration property for setting the number of events that we will try to 'batch'
* up before sending them to the event bus. */
- public final static String PARAM_EVENT_STREAM_BATCH_SIZE = "champ.event.stream.batch-size";
- public final static Integer DEFAULT_EVENT_STREAM_BATCH_SIZE = 1;
+ public static final String PARAM_EVENT_STREAM_BATCH_SIZE = "champ.event.stream.batch-size";
+ public static final Integer DEFAULT_EVENT_STREAM_BATCH_SIZE = 1;
/** Configuration property for setting the maximum amount of time to wait for a batch of
* outgoing messages to fill up before sending the batch. */
- public final static String PARAM_EVENT_STREAM_BATCH_TIMEOUT = "champ.event.stream.batch-timeout";
- public final static Integer DEFAULT_EVENT_STREAM_BATCH_TIMEOUT_MS = 500;
+ public static final String PARAM_EVENT_STREAM_BATCH_TIMEOUT = "champ.event.stream.batch-timeout";
+ public static final Integer DEFAULT_EVENT_STREAM_BATCH_TIMEOUT_MS = 500;
- public final static String PARAM_EVENT_STREAM_PUBLISHER_POOL_SIZE = "champ.event.stream.publisher-pool-size";
- public final static Integer DEFAULT_EVENT_STREAM_PUBLISHER_POOL_SIZE = 100;
+ public static final String PARAM_EVENT_STREAM_PUBLISHER_POOL_SIZE = "champ.event.stream.publisher-pool-size";
+ public static final Integer DEFAULT_EVENT_STREAM_PUBLISHER_POOL_SIZE = 100;
/** The event stream topic that we will publish Champ events to. */
- public final static String EVENT_TOPIC = "champRawEvents";
+ public static final String EVENT_TOPIC = "champRawEvents";
/** Number of events to 'batch up' before actually publishing them to the event bus. */
private Integer eventStreamBatchSize;
objectToDelete = retrieveObject(key);
} catch (ChampUnmarshallingException e) {
- logger.error("Unable to generate delete object log: " + e.getMessage());
+ logger.error("Unable to generate delete object log: " + e.getMessage(),e);
}
executeDeleteObject(key);
publisherPool.execute(new EventPublisher(anEvent));
} catch (RejectedExecutionException re) {
- logger.error("Event could not be published to the event bus due to: " + re.getMessage());
+ logger.error("Event could not be published to the event bus due to: " + re.getMessage(),re);
} catch (NullPointerException npe) {
- logger.error("Can not publish null event to event bus.");
+ logger.error("Can not publish null event to event bus." + npe.getMessage(),npe);
}
}