org.slf4j.cal10n.LocLogger.isDebugEnabled()方法的使用及代码示例

本文整理了Java中org.slf4j.cal10n.LocLogger.isDebugEnabled()方法的一些代码示例，展示了LocLogger.isDebugEnabled()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。LocLogger.isDebugEnabled()方法的具体详情如下：
包路径：org.slf4j.cal10n.LocLogger
类名称：LocLogger
方法名：isDebugEnabled

LocLogger.isDebugEnabled介绍

暂无

代码示例

代码示例来源：origin: sitewhere/sitewhere

@Override
public String encode(IDeviceCommandExecution command, IDeviceNestingContext nested, IDeviceAssignment assignment)
throws SiteWhereException {
EncodedCommandExecution encoded = new EncodedCommandExecution(command, nested, assignment);
if (getLogger().isDebugEnabled()) {
getLogger().debug("Custom command being encoded:\n\n" + MarshalUtils.marshalJsonAsPrettyString(encoded));
}
return new String(MarshalUtils.marshalJson(encoded));
}

代码示例来源：origin: sitewhere/sitewhere

@Override
public String encodeSystemCommand(ISystemCommand command, IDeviceNestingContext nested,
IDeviceAssignment assignment) throws SiteWhereException {
EncodedCommandExecution encoded = new EncodedCommandExecution(command, nested, assignment);
if (getLogger().isDebugEnabled()) {
getLogger().debug("System command being encoded:\n\n" + MarshalUtils.marshalJsonAsPrettyString(encoded));
}
return new String(MarshalUtils.marshalJson(encoded));
}
}

代码示例来源：origin: sitewhere/sitewhere

/**
* Process an inbound payload into an assignment event create request.
*
* @param record
* @return
* @throws SiteWhereException
*/
protected GInboundEventPayload decodeRequest(ConsumerRecord record) throws SiteWhereException {
GInboundEventPayload message = EventModelMarshaler.parseInboundEventPayloadMessage(record.value());
if (getLogger().isDebugEnabled()) {
InboundEventPayload payload = EventModelConverter.asApiInboundEventPayload(message);
getLogger().debug("Received decoded event payload:\n\n" + MarshalUtils.marshalJsonAsPrettyString(payload));
}
return message;
}

代码示例来源：origin: sitewhere/sitewhere

/**
* Process a single record.
*
* @param record
* @throws SiteWhereException
*/
protected void processRecord(ConsumerRecord record) throws SiteWhereException {
getProcessedEvents().mark();
try {
GEnrichedEventPayload grpc = EventModelMarshaler.parseEnrichedEventPayloadMessage(record.value());
EnrichedEventPayload payload = EventModelConverter.asApiEnrichedEventPayload(grpc);
if (getLogger().isDebugEnabled()) {
getLogger().debug(
"Received enriched event payload:\n\n" + MarshalUtils.marshalJsonAsPrettyString(payload));
}
processDeviceStateEvent(payload);
} catch (SiteWhereException e) {
getLogger().error("Unable to process outbound connector event payload.", e);
} catch (Throwable e) {
getLogger().error("Unhandled exception processing connector event payload.", e);
}
}

代码示例来源：origin: sitewhere/sitewhere

@Override
public ISearchResults listDeviceAssignments(IDeviceAssignmentSearchCriteria criteria)
throws SiteWhereException {
if (getLogger().isDebugEnabled()) {
getLogger().debug("Assignment search criteria:\n\n" + MarshalUtils.marshalJsonAsPrettyString(criteria));
}
MongoCollection assignments = getMongoClient().getDeviceAssignmentsCollection();
Document query = new Document();
if (criteria.getStatus() != null) {
query.append(MongoDeviceAssignment.PROP_STATUS, criteria.getStatus().name());
}
if (criteria.getDeviceId() != null) {
query.append(MongoDeviceAssignment.PROP_DEVICE_ID, criteria.getDeviceId());
}
if ((criteria.getCustomerIds() != null) && (criteria.getCustomerIds().size() > 0)) {
query.append(MongoDeviceAssignment.PROP_CUSTOMER_ID, new Document("$in", criteria.getCustomerIds()));
}
if ((criteria.getAreaIds() != null) && (criteria.getAreaIds().size() > 0)) {
query.append(MongoDeviceAssignment.PROP_AREA_ID, new Document("$in", criteria.getAreaIds()));
}
if ((criteria.getAssetIds() != null) && (criteria.getAssetIds().size() > 0)) {
query.append(MongoDeviceAssignment.PROP_ASSET_ID, new Document("$in", criteria.getAssetIds()));
}
Document sort = new Document(MongoDeviceAssignment.PROP_ACTIVE_DATE, -1);
return MongoPersistence.search(IDeviceAssignment.class, assignments, query, sort, criteria, LOOKUP);
}

代码示例来源：origin: sitewhere/sitewhere

/**
* Process a single device event.
*
* @param context
* @param event
* @throws SiteWhereException
*/
protected void processDeviceEvent(IDeviceEventContext context, IDeviceEvent event) throws SiteWhereException {
try {
if ((getUriBuilder() != null) && (getPayloadBuilder() != null)) {
String uri = getUriBuilder().buildUri(this, context, event);
byte[] payload = getPayloadBuilder().buildPayload(this, context, event);
if ("post".equalsIgnoreCase(method)) {
getClient().postForLocation(uri, payload);
} else if ("put".equalsIgnoreCase(method)) {
getClient().put(uri, payload);
}
} else {
getLogger().warn("Skipping HTTP outbound event due to missing configuration.");
}
} catch (RestClientException e) {
getLogger().error(String.format("Unable to send HTTP payload: %s", e.getMessage()));
if (getLogger().isDebugEnabled()) {
getLogger().error("Error sending payload via REST client.", e);
}
}
}

代码示例来源：origin: sitewhere/sitewhere

@Override
public void runAsSystemUser() throws SiteWhereException {
try {
GPersistedEventPayload grpc = EventModelMarshaler.parsePersistedEventPayloadMessage(encoded);
if (getLogger().isDebugEnabled()) {
PersistedEventPayload payload = EventModelConverter.asApiPersisedEventPayload(grpc);
getLogger().debug(
"Received persisted event payload:\n\n" + MarshalUtils.marshalJsonAsPrettyString(payload));
}
getOutboundPayloadEnrichmentLogic().process(grpc);
} catch (SiteWhereException e) {
getLogger().error("Unable to parse persisted event payload.", e);
}
}
}

代码示例来源：origin: sitewhere/sitewhere

@Override
public void runAsSystemUser() throws SiteWhereException {
List decoded = new ArrayList<>();
for (ConsumerRecord record : getRecords()) {
try {
GEnrichedEventPayload grpc = EventModelMarshaler.parseEnrichedEventPayloadMessage(record.value());
EnrichedEventPayload payload = EventModelConverter.asApiEnrichedEventPayload(grpc);
if (getLogger().isDebugEnabled()) {
getLogger().debug("Received enriched event payload:\n\n"
+ MarshalUtils.marshalJsonAsPrettyString(payload));
}
decoded.add(payload);
} catch (SiteWhereException e) {
getLogger().error("Unable to parse outbound connector event payload.", e);
} catch (Throwable e) {
getLogger().error("Unhandled exception parsing connector event payload.", e);
}
}
try {
getOutboundConnector().processEventBatch(decoded);
} catch (SiteWhereException e) {
getOutboundConnector().handleFailedBatch(decoded, e);
getLogger().error("Unable to process outbound connector batch.", e);
} catch (Throwable e) {
getOutboundConnector().handleFailedBatch(decoded, e);
getLogger().error("Unhandled exception processing connector batch.", e);
}
}

代码示例来源：origin: sitewhere/sitewhere

/**
* Handle processing of a single record.
*
* @param key
* @param message
* @throws SiteWhereException
*/
public void received(String key, byte[] message) throws SiteWhereException {
try {
GUnprocessedBatchElement grpc = BatchModelMarshaler.parseUnprocessedBatchElementPayloadMessage(message);
UnprocessedBatchElement unprocessed = BatchModelConverter.asApiUnprocessedBatchElement(grpc);
if (getLogger().isDebugEnabled()) {
getLogger().debug("Received unprocessed batch element payload:\n\n"
+ MarshalUtils.marshalJsonAsPrettyString(unprocessed));
}
getBatchOperationManager().processBatchElement(unprocessed);
} catch (SiteWhereException e) {
getLogger().error("Unable to parse batch operation payload.", e);
}
}

代码示例来源：origin: sitewhere/sitewhere

/**
* Handle processing of a single record.
*
* @param key
* @param message
* @throws SiteWhereException
*/
public void received(String key, byte[] message) throws SiteWhereException {
try {
GUnprocessedBatchOperation grpc = BatchModelMarshaler.parseUnprocessedBatchOperationPayloadMessage(message);
UnprocessedBatchOperation unprocessed = BatchModelConverter.asApiUnprocessedBatchOperation(grpc);
if (getLogger().isDebugEnabled()) {
getLogger().debug("Received unprocessed batch operation payload:\n\n"
+ MarshalUtils.marshalJsonAsPrettyString(unprocessed));
}
getBatchOperationManager().initializeBatchOperation(unprocessed);
} catch (SiteWhereException e) {
getLogger().error("Unable to parse batch operation payload.", e);
}
}

代码示例来源：origin: sitewhere/sitewhere

@Override
public void runAsSystemUser() throws SiteWhereException {
try {
GEnrichedEventPayload grpc = EventModelMarshaler.parseEnrichedEventPayloadMessage(encoded);
EnrichedEventPayload payload = EventModelConverter.asApiEnrichedEventPayload(grpc);
if (getLogger().isDebugEnabled()) {
getLogger().debug(
"Received enriched event payload:\n\n" + MarshalUtils.marshalJsonAsPrettyString(payload));
}
routePayload(payload);
} catch (SiteWhereException e) {
getLogger().error("Unable to process rule processor event payload.", e);
} catch (Throwable e) {
getLogger().error("Unhandled exception processing rule processor event payload.", e);
}
}

代码示例来源：origin: sitewhere/sitewhere

@Override
public void runAsSystemUser() throws SiteWhereException {
try {
GInboundEventPayload grpc = EventModelMarshaler.parseInboundEventPayloadMessage(encoded);
InboundEventPayload eventPayload = EventModelConverter.asApiInboundEventPayload(grpc);
if (getLogger().isDebugEnabled()) {
getLogger().debug("Received event for unregistered device:\n\n"
+ MarshalUtils.marshalJsonAsPrettyString(eventPayload));
}
// Pass payload to registration manager.
((IDeviceRegistrationTenantEngine) getTenantEngine()).getRegistrationManager()
.handleUnregisteredDeviceEvent(eventPayload);
} catch (SiteWhereException e) {
getLogger().error("Unable to parse unregistered device event payload.", e);
} catch (Throwable e) {
getLogger().error("Unhandled exception parsing unregistered device event payload.", e);
}
}
}

代码示例来源：origin: sitewhere/sitewhere

@Override
public void runAsSystemUser() throws SiteWhereException {
try {
GDeviceRegistationPayload grpc = DeviceModelMarshaler.parseDeviceRegistrationPayloadMessage(encoded);
DeviceRegistrationPayload payload = DeviceModelConverter.asApiDeviceRegistrationPayload(grpc);
if (getLogger().isDebugEnabled()) {
getLogger().debug(
"Received registration for device:\n\n" + MarshalUtils.marshalJsonAsPrettyString(payload));
}
// Pass payload to registration manager.
((IDeviceRegistrationTenantEngine) getTenantEngine()).getRegistrationManager()
.handleDeviceRegistration(payload);
} catch (SiteWhereException e) {
getLogger().error("Error processing device registration.", e);
} catch (Throwable e) {
getLogger().error("Unhandled exception processing device registration.", e);
}
}
}

代码示例来源：origin: sitewhere/sitewhere

@Override
public void runAsSystemUser() throws SiteWhereException {
try {
GEnrichedEventPayload grpc = EventModelMarshaler.parseEnrichedEventPayloadMessage(encoded);
EnrichedEventPayload eventPayload = EventModelConverter.asApiEnrichedEventPayload(grpc);
if (getLogger().isDebugEnabled()) {
getLogger().debug(
"Received command invocation:\n\n" + MarshalUtils.marshalJsonAsPrettyString(eventPayload));
}
// Pass decoded payload to processing strategy implementation.
ICommandProcessingStrategy strategy = ((ICommandDeliveryTenantEngine) getTenantEngine())
.getCommandProcessingStrategy();
IDeviceCommandInvocation invocation = (IDeviceCommandInvocation) eventPayload.getEvent();
strategy.deliverCommand(eventPayload.getEventContext(), invocation);
} catch (SiteWhereException e) {
getLogger().error("Unable to parse unregistered device event payload.", e);
} catch (Throwable e) {
getLogger().error("Unhandled exception parsing unregistered device event payload.", e);
}
}
}