Skip to content
Browse files

Package comments and gofmt.

  • Loading branch information...
1 parent f9a3042 commit 525e1164642f705c4a83f3d0d0e330d43d71d06c @gmallard committed Mar 24, 2012
Showing with 97 additions and 37 deletions.
  1. +3 −1 abort.go
  2. +3 −1 ack.go
  3. +3 −2 ack_test.go
  4. +3 −1 begin.go
  5. +3 −1 codec_test.go
  6. +3 −1 commit.go
  7. +4 −1 conndisc_test.go
  8. +3 −1 connect.go
  9. +3 −1 connection.go
  10. +3 −1 data.go
  11. +3 −1 data_test.go
  12. +3 −1 datafuncs.go
  13. +3 −1 disconnect.go
  14. +3 −1 hb_test.go
  15. +3 −1 heartbeats.go
  16. +3 −1 logger_test.go
  17. +3 −1 nack.go
  18. +3 −1 nack_test.go
  19. +3 −1 reader.go
  20. +3 −1 send.go
  21. +3 −1 send_test.go
  22. +3 −2 sub_test.go
  23. +6 −4 subscribe.go
  24. +3 −1 trans_test.go
  25. +3 −1 transmit.go
  26. +3 −1 unsub_test.go
  27. +3 −1 unsubscribe.go
  28. +3 −1 utils.go
  29. +3 −1 utils_test.go
  30. +3 −1 writer.go
  31. +3 −2 wrsubrduns_test.go
View
4 abort.go
@@ -13,7 +13,9 @@
// See the License for the specific language governing permissions and
// limitations under the License.
//
-
+/*
+A STOMP 1.1 Compatible Client Library
+*/
package stompngo
// Abort STOMP transaction. Headers must contain a "transaction" header key
View
4 ack.go
@@ -13,7 +13,9 @@
// See the License for the specific language governing permissions and
// limitations under the License.
//
-
+/*
+A STOMP 1.1 Compatible Client Library
+*/
package stompngo
// Ack a STOMP MESSAGE. Headers must contain a "message-id" key, and for
View
5 ack_test.go
@@ -13,7 +13,9 @@
// See the License for the specific language governing permissions and
// limitations under the License.
//
-
+/*
+A STOMP 1.1 Compatible Client Library
+*/
package stompngo
import (
@@ -197,4 +199,3 @@ func TestAckDiffConn(t *testing.T) {
_ = closeConn(t, n)
}
-
View
4 begin.go
@@ -13,7 +13,9 @@
// See the License for the specific language governing permissions and
// limitations under the License.
//
-
+/*
+A STOMP 1.1 Compatible Client Library
+*/
package stompngo
// Begin a STOMP transaction. Headers must contain a "transaction" header key
View
4 codec_test.go
@@ -13,7 +13,9 @@
// See the License for the specific language governing permissions and
// limitations under the License.
//
-
+/*
+A STOMP 1.1 Compatible Client Library
+*/
package stompngo
import (
View
4 commit.go
@@ -13,7 +13,9 @@
// See the License for the specific language governing permissions and
// limitations under the License.
//
-
+/*
+A STOMP 1.1 Compatible Client Library
+*/
package stompngo
// Commit a STOMP transaction. Headers must contain a "transaction" header key
View
5 conndisc_test.go
@@ -13,12 +13,15 @@
// See the License for the specific language governing permissions and
// limitations under the License.
//
-
+/*
+A STOMP 1.1 Compatible Client Library
+*/
package stompngo
import (
"testing"
)
+
// ConnDisc Test: Netconn
func TestConnDiscNetconn(t *testing.T) {
n, _ := openConn(t)
View
4 connect.go
@@ -13,7 +13,9 @@
// See the License for the specific language governing permissions and
// limitations under the License.
//
-
+/*
+A STOMP 1.1 Compatible Client Library
+*/
package stompngo
import (
View
4 connection.go
@@ -13,7 +13,9 @@
// See the License for the specific language governing permissions and
// limitations under the License.
//
-
+/*
+A STOMP 1.1 Compatible Client Library
+*/
package stompngo
import (
View
4 data.go
@@ -13,7 +13,9 @@
// See the License for the specific language governing permissions and
// limitations under the License.
//
-
+/*
+A STOMP 1.1 Compatible Client Library
+*/
package stompngo
import (
View
4 data_test.go
@@ -13,7 +13,9 @@
// See the License for the specific language governing permissions and
// limitations under the License.
//
-
+/*
+A STOMP 1.1 Compatible Client Library
+*/
package stompngo
import (
View
4 datafuncs.go
@@ -13,7 +13,9 @@
// See the License for the specific language governing permissions and
// limitations under the License.
//
-
+/*
+A STOMP 1.1 Compatible Client Library
+*/
package stompngo
import (
View
4 disconnect.go
@@ -13,7 +13,9 @@
// See the License for the specific language governing permissions and
// limitations under the License.
//
-
+/*
+A STOMP 1.1 Compatible Client Library
+*/
package stompngo
// Disconnect from a STOMP broker. Shut down heart beats if necessary.
View
4 hb_test.go
@@ -13,7 +13,9 @@
// See the License for the specific language governing permissions and
// limitations under the License.
//
-
+/*
+A STOMP 1.1 Compatible Client Library
+*/
package stompngo
import (
View
4 heartbeats.go
@@ -13,7 +13,9 @@
// See the License for the specific language governing permissions and
// limitations under the License.
//
-
+/*
+A STOMP 1.1 Compatible Client Library
+*/
package stompngo
import (
View
4 logger_test.go
@@ -13,7 +13,9 @@
// See the License for the specific language governing permissions and
// limitations under the License.
//
-
+/*
+A STOMP 1.1 Compatible Client Library
+*/
package stompngo
import (
View
4 nack.go
@@ -13,7 +13,9 @@
// See the License for the specific language governing permissions and
// limitations under the License.
//
-
+/*
+A STOMP 1.1 Compatible Client Library
+*/
package stompngo
// Nack a STOMP 1.1+ message. Headers must contain a "message-id" key and
View
4 nack_test.go
@@ -13,7 +13,9 @@
// See the License for the specific language governing permissions and
// limitations under the License.
//
-
+/*
+A STOMP 1.1 Compatible Client Library
+*/
package stompngo
import (
View
4 reader.go
@@ -13,7 +13,9 @@
// See the License for the specific language governing permissions and
// limitations under the License.
//
-
+/*
+A STOMP 1.1 Compatible Client Library
+*/
package stompngo
import (
View
4 send.go
@@ -13,7 +13,9 @@
// See the License for the specific language governing permissions and
// limitations under the License.
//
-
+/*
+A STOMP 1.1 Compatible Client Library
+*/
package stompngo
// Send a STOMP MESSAGE. Headers must contain a "destination" header.
View
4 send_test.go
@@ -13,7 +13,9 @@
// See the License for the specific language governing permissions and
// limitations under the License.
//
-
+/*
+A STOMP 1.1 Compatible Client Library
+*/
package stompngo
import (
View
5 sub_test.go
@@ -13,7 +13,9 @@
// See the License for the specific language governing permissions and
// limitations under the License.
//
-
+/*
+A STOMP 1.1 Compatible Client Library
+*/
package stompngo
import (
@@ -202,4 +204,3 @@ func TestSubUnsubBasic10(t *testing.T) {
_ = c.Disconnect(empty_headers)
_ = closeConn(t, n)
}
-
View
10 subscribe.go
@@ -13,11 +13,13 @@
// See the License for the specific language governing permissions and
// limitations under the License.
//
-
+/*
+A STOMP 1.1 Compatible Client Library
+*/
package stompngo
import (
- "log"
+ "log"
)
// Subscribe to a STOMP subscription. Headers must contain a "destintion" header,
@@ -76,8 +78,8 @@ func (c *Connection) establishSubscription(h Headers) (chan MessageData, error,
if hid { // If 1.0 client wants one, assign it.
c.subs[sid] = make(chan MessageData)
} else {
- return c.input, nil, h // 1.0 clients with no id take their own chances
- }
+ return c.input, nil, h // 1.0 clients with no id take their own chances
+ }
case SPL_11:
if hid { // Client specified id
c.subs[sid] = make(chan MessageData) // Assign subscription
View
4 trans_test.go
@@ -13,7 +13,9 @@
// See the License for the specific language governing permissions and
// limitations under the License.
//
-
+/*
+A STOMP 1.1 Compatible Client Library
+*/
package stompngo
import (
View
4 transmit.go
@@ -13,7 +13,9 @@
// See the License for the specific language governing permissions and
// limitations under the License.
//
-
+/*
+A STOMP 1.1 Compatible Client Library
+*/
package stompngo
// Common send for many stomp API calls.
View
4 unsub_test.go
@@ -13,7 +13,9 @@
// See the License for the specific language governing permissions and
// limitations under the License.
//
-
+/*
+A STOMP 1.1 Compatible Client Library
+*/
package stompngo
import (
View
4 unsubscribe.go
@@ -13,7 +13,9 @@
// See the License for the specific language governing permissions and
// limitations under the License.
//
-
+/*
+A STOMP 1.1 Compatible Client Library
+*/
package stompngo
// Unsubscribe from a STOMP subscription. Headers must contain a "destintion" header,
View
4 utils.go
@@ -13,7 +13,9 @@
// See the License for the specific language governing permissions and
// limitations under the License.
//
-
+/*
+A STOMP 1.1 Compatible Client Library
+*/
package stompngo
import (
View
4 utils_test.go
@@ -13,7 +13,9 @@
// See the License for the specific language governing permissions and
// limitations under the License.
//
-
+/*
+A STOMP 1.1 Compatible Client Library
+*/
package stompngo
import (
View
4 writer.go
@@ -13,7 +13,9 @@
// See the License for the specific language governing permissions and
// limitations under the License.
//
-
+/*
+A STOMP 1.1 Compatible Client Library
+*/
package stompngo
import (
View
5 wrsubrduns_test.go
@@ -13,7 +13,9 @@
// See the License for the specific language governing permissions and
// limitations under the License.
//
-
+/*
+A STOMP 1.1 Compatible Client Library
+*/
package stompngo
import (
@@ -84,4 +86,3 @@ func TestShovel11(t *testing.T) {
_ = c.Disconnect(empty_headers)
_ = closeConn(t, n)
}
-

0 comments on commit 525e116

Please sign in to comment.
Something went wrong with that request. Please try again.