Skip to content

Commit

Permalink
v1.1.4 fixed bug in topic name lookups for ignite topics
Browse files Browse the repository at this point in the history
  • Loading branch information
dstieglitz committed Oct 3, 2018
1 parent ee4c1b4 commit f938bb3
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 4 deletions.
2 changes: 1 addition & 1 deletion IgniteGrailsPlugin.groovy
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@ import org.grails.ignite.TaskDecorator

class IgniteGrailsPlugin {
// the plugin version
def version = "1.1.3"
def version = "1.1.4"
// the version or versions of Grails the plugin is designed for
def grailsVersion = "2.3 > *"
// resources that are excluded from plugin packaging
Expand Down
6 changes: 3 additions & 3 deletions src/java/org/grails/ignite/MessageBrokerImpl.java
Original file line number Diff line number Diff line change
Expand Up @@ -138,7 +138,7 @@ public void sendMessage(Map destinationData, Object message) throws MessageBroke
@Override
public Future sendMessageAsync(Map destinationData, Object message) {
// log.warn("All message sending is asynchronous now");
log.debug("sendMessage(" + destinationData + "," + message + ")");
log.debug("sendMessageAsync(" + destinationData + "," + message + ")");

if (destinationData.containsKey("queue")) {
String queueName = (String) destinationData.get("queue");
Expand All @@ -150,8 +150,8 @@ public Future sendMessageAsync(Map destinationData, Object message) {
} else if (destinationData.containsKey("topic")) {
String topicName = (String) destinationData.get("topic");
MessageWrapperFuture f = new MessageWrapperFuture(destinationData, (Serializable) message);
log.debug("sending to topic: " + destinationData.get("topic") + "," + message + ", with timeout=" + TIMEOUT);
ignite.message().sendOrdered(destinationData, message, TIMEOUT);
log.debug("async sending to topic: " + destinationData.get("topic") + "," + message + ", with timeout=" + TIMEOUT);
ignite.message().sendOrdered(destinationData.get("topic"), message, TIMEOUT);
f.consumed();
return f;
}
Expand Down

0 comments on commit f938bb3

Please sign in to comment.