sendbytes.go

   1 //
   2 // Copyright © 2014-2019 Guy M. Allard
   3 //
   4 // Licensed under the Apache License, Version 2.0 (the "License");
   5 // you may not use this file except in compliance with the License.
   6 // You may obtain a copy of the License at
   7 //
   8 //     http://www.apache.org/licenses/LICENSE-2.0
   9 //
  10 // Unless required by applicable law or agreed to in writing, software
  11 // distributed under the License is distributed on an "AS IS" BASIS,
  12 // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  13 // See the License for the specific language governing permissions and
  14 // limitations under the License.
  15 //
  16
  17 package stompngo
  18
  19 /*
  20         Send a STOMP MESSAGE.
  21
  22         Headers MUST contain a "destination" header key.
  23
  24         The message body (payload) is a slice of bytes, which may be empty.
  25
  26         Example:
  27                 h := stompngo.Headers{stompngo.HK_DESTINATION, "/queue/mymessages"}
  28                 m := []byte("My message")
  29                 e := c.Send(h, m)
  30                 if e != nil {
  31                         // Do something sane ...
  32                 }
  33
  34 */
  35 func (c *Connection) SendBytes(h Headers, b []byte) error {
  36         c.log(SEND, "start", h)
  37         if !c.isConnected() {
  38                 return ECONBAD
  39         }
  40         e := checkHeaders(h, c.Protocol())
  41         if e != nil {
  42                 return e
  43         }
  44         if _, ok := h.Contains(HK_DESTINATION); !ok {
  45                 return EREQDSTSND
  46         }
  47         ch := h.Clone()
  48         f := Frame{SEND, ch, b}
  49         r := make(chan error)
  50         if e = c.writeWireData(wiredata{f, r}); e != nil {
  51                 return e
  52         }
  53         e = <-r
  54         c.log(SEND, "end", ch)
  55         return e // nil or not
  56 }