You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
The implementation checks if the destination is of type NevadoTopic before it deletes the message. It should probably check that it is "Topic" in case it is a non-Nevado topic.
public class NevadoSession implements Session {
.......
protected NevadoMessage receiveMessage(NevadoDestination destination, long timeoutMs, boolean noLocal)
throws JMSException, InterruptedException {
…….
// Filter noLocal matches
line 437: if (message != null && destination instanceof NevadoTopic && noLocal && _connection.getConnectionID()
.equals(message.getNevadoProperty(NevadoProperty.ConnectionID)))
{
deleteMessage(message);
message = null;
}
}
……..
}
.....
}
The text was updated successfully, but these errors were encountered:
Unable to reproduce. Whenever NevadoSession creates a consumer or a producer with a foreign implementation of a Destination, it will transform it into a NevadoDestination using NevadoDestination.getInstance(destination);
The implementation checks if the destination is of type NevadoTopic before it deletes the message. It should probably check that it is "Topic" in case it is a non-Nevado topic.
.....
}
The text was updated successfully, but these errors were encountered: