*/
public IResponse handleCreateSubtopic(IRequest request) {
- String newTopicName = request.getUriPathSegments().get(
- request.getUriPathSegments().size() - 1);
+ String newTopicName = request.getUriPathSegments()
+ .get(request.getUriPathSegments().size() - 1);
String newTopicType = new String();
}
synchronized (mSubscribers) {
- mSubscribers.put(request.getRequestId(), new TopicSubscriber(
- srcDevice, request));
+ mSubscribers.put(request.getRequestId(),
+ new TopicSubscriber(srcDevice, request));
}
return MessageBuilder.createResponse(request, ResponseStatus.CONTENT,
synchronized (mSubscribers) {
- TopicSubscriber subscriber = mSubscribers.get(request
- .getRequestId());
+ TopicSubscriber subscriber = mSubscribers
+ .get(request.getRequestId());
mSubscribers.remove(subscriber.mRequest.getRequestId());
HashMap<String, Object> message = mCbor.parsePayloadFromCbor(payload,
HashMap.class);
- if (message == null
- || message.containsKey(Constants.MQ_MESSAGE) == false) {
- throw new PreconditionFailedException(
- "message field is not included");
+ if (message == null || message.isEmpty()) {
+ throw new PreconditionFailedException("message is not included");
}
if (mKafkaProducerOperator.publishMessage(payload) == false) {
synchronized (mSubscribers) {
for (TopicSubscriber subscriber : mSubscribers.values()) {
- subscriber.mSubscriber.sendResponse(MessageBuilder
- .createResponse(subscriber.mRequest,
+ subscriber.mSubscriber.sendResponse(
+ MessageBuilder.createResponse(subscriber.mRequest,
ResponseStatus.CONTENT,
ContentFormat.APPLICATION_CBOR, mLatestData));
}