|
@@ -63,13 +63,13 @@ func (c *Connection) Submit(msg Message) {
|
|
|
|
|
|
// Publish will publish a message , and return a chan to wait for completion.
|
|
|
func (c *Connection) Publish(msg Message, timeout time.Duration) error {
|
|
|
- server.Log.Debugf("publishing message : %v, timeout %v", msg, timeout)
|
|
|
+
|
|
|
|
|
|
message := msg.(*Publish)
|
|
|
message.MessageID = c.MessageID
|
|
|
c.MessageID++
|
|
|
c.Submit(message)
|
|
|
-
|
|
|
+ server.Log.Debugf("publishing message : %v, timeout %v", msg, timeout)
|
|
|
ch := make(chan error)
|
|
|
|
|
|
// we don't wait for confirm.
|