NO-JIRA: Add handler event root tests
Project: http://git-wip-us.apache.org/repos/asf/qpid-proton/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-proton/commit/5598d501
Tree: http://git-wip-us.apache.org/repos/asf/qpid-proton/tree/5598d501
Diff: http://git-wip-us.apache.org/repos/asf/qpi
PROTON-827: Switch go directory and symlink locations, problems with some go
tools.
godoc and godep don't work well with the symlink.
Project: http://git-wip-us.apache.org/repos/asf/qpid-proton/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-proton/commit/9276ae33
Tree: http://git-wip-
if context == linkPump {
+ if context == nil {
+ log.Fatal("pop in nil context")
+ }
+ link.Send(message) // link is in the current pump, safe
to call Send() direct
+ } e
PROTON-865: add timer tasks, cancellation, recurring_timer example
Project: http://git-wip-us.apache.org/repos/asf/qpid-proton/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-proton/commit/705284bc
Tree: http://git-wip-us.apache.org/repos/asf/qpid-proton/tree/705284bc
Diff: http://git-wi
(h cHandler) HandleEvent(e Event) error {
+ C.pn_handler_dispatch(h.pn, e.pn, C.pn_event_type(e.pn))
+ return nil // FIXME aconway 2015-03-31: error handling
+}
+
+// MessagingHandler provides an alternative interface to EventHandler.
+// it is easier to use for most applications that send and
uint64)
- func (@"reflect".v·2 @"reflect".Value "esc:0x2") UnsafeAddr () (?
uintptr)
- func (@"reflect".v·2 @"reflect".Value) @"reflect".assignTo
(@"reflect".context·3 string "esc:0x0", @"reflect&quo
t exported fields to configure the connection before calling
+// Connection.Open()
+//
+type Connection struct {
+ // Server = true means a the connection will do automatic protocol
detection.
+ Server bool
+
+ // FIXME aconway 2015-04-17: Other parameters to set up SSL, SASL
+78,11 @@ func (b *broker) check() error {
// Start the demo broker, wait till it is listening on *addr. No-op if already
started.
func (b *broker) start() error {
- build("event_broker.go")
if b.cmd == nil { // Not already started
// FIXME aconway 2015-04-
amqp
-
-// #include
-// #include
-// #include
-import "C"
-
-import (
- "qpid.apache.org/proton/go/internal"
- "time"
- "unsafe"
-)
-
-// FIXME aconway 2015-04-28: Do we need the interface or can we just export
the struct?
-
-// Messag
erlying proton C engine.
+
+AMQP is an open standard for inter-operable message exchange, see
<http://www.amqp.org/>
+*/
+package amqp
+
+// #cgo LDFLAGS: -lqpid-proton
+import "C"
+
+// This file is just for
NO-JIRA: Add event root to python bindings
Project: http://git-wip-us.apache.org/repos/asf/qpid-proton/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-proton/commit/f9e9ca99
Tree: http://git-wip-us.apache.org/repos/asf/qpid-proton/tree/f9e9ca99
Diff: http://git-wip-us.apache.org/repos/as
(ASF) under one
-or more contributor license agreements. See the NOTICE file
-distributed with this work for additional information
-regarding copyright ownership. The ASF licenses this file
-to you under the Apache License, Version 2.0 (the
-"License"); you may not use this file except in compli
len(data) {
+ return nil, internal.Errorf("cannot receive message: %s",
internal.PnErrorCode(result))
+ }
+ return amqp.DecodeMessage(data)
+}
+
+// FIXME aconway 2015-04-08: proper handling of delivery tags. Tag counter per
link.
+var tags amqp.UidCounter
+
the underlying proton C engine.
-
-AMQP is an open standard for inter-operable message exchange, see
<http://www.amqp.org/>
-*/
-package amqp
-
-// #cgo LDFLAGS: -lqpid-proton
-import "C"
-
-// This file is just for
(ASF) under one
-or more contributor license agreements. See the NOTICE file
-distributed with this work for additional information
-regarding copyright ownership. The ASF licenses this file
-to you under the Apache License, Version 2.0 (the
-"License"); you may not use this file except in compli
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/9276ae33/proton-c/bindings/go/pkg/linux_amd64/qpid.apache.org/proton/go/messaging.a
--
diff --git
a/proton-c/bindings/go/pkg/linux_amd64/qpid.apache.org/proton/go/messaging.a
N_SYMBOL:
- return "symbol"
- case C.PN_DESCRIBED:
- return "described"
- case C.PN_ARRAY:
- return "array"
- case C.PN_LIST:
- return "list"
- case C.PN_MAP:
- return "map"
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/9276ae33/proton-c/bindings/go/pkg/linux_amd64/qpid.apache.org/proton/go/messaging.a
--
diff --git
a/proton-c/bindings/go/pkg/linux_amd64/qpid.apache.org/proton/go/messaging.a
ying proton C engine.
+
+AMQP is an open standard for inter-operable message exchange, see
<http://www.amqp.org/>
+*/
+package amqp
+
+// #cgo LDFLAGS: -lqpid-proton
+import "C"
+
+// This file is just for the package comment.
+
+// FIXME aconway 2015-04-28: need to re-organize the p
NO-JIRA: Python: keep received encoded bytes in the delivery
Project: http://git-wip-us.apache.org/repos/asf/qpid-proton/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-proton/commit/7de6a183
Tree: http://git-wip-us.apache.org/repos/asf/qpid-proton/tree/7de6a183
Diff: http://git-wip-us.a
quot;esc:0x0") Hostname () (? string)
- func (@"".c·2 @"".Connection "esc:0x0") IsNil () (? bool) { return
@"".c·2.@"".pn == nil }
- func (@"".c·2 @"".Connection "esc:0x0") LinkHead (@&quo
+78,11 @@ func (b *broker) check() error {
// Start the demo broker, wait till it is listening on *addr. No-op if already
started.
func (b *broker) start() error {
- build("event_broker.go")
if b.cmd == nil { // Not already started
// FIXME aconway
ing(data))
+ case C.PN_SYMBOL:
+ *v = Symbol(goString(C.pn_data_get_symbol(data)))
+ case C.PN_MAP:
+ m := make(Map)
+ get(data, &m)
+ *v = m // FIXME aconway 2015-03-13: avoid the copy?
+ case C.PN_LIST:
+ l := make(List, 0
NO-JIRA: Add Event.getRootHandler()
Project: http://git-wip-us.apache.org/repos/asf/qpid-proton/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-proton/commit/3cb935f1
Tree: http://git-wip-us.apache.org/repos/asf/qpid-proton/tree/3cb935f1
Diff: http://git-wip-us.apache.org/repos/asf/qpid-
ll
+++ b/proton-c/bindings/go/src/qpid.apache.org/proton/go/amqp/doc.go
@@ -0,0 +1,40 @@
+/*
+Licensed to the Apache Software Foundation (ASF) under one
+or more contributor license agreements. See the NOTICE file
+distributed with this work for additional information
+regarding copyright owne
the underlying proton C engine.
-
-AMQP is an open standard for inter-operable message exchange, see
<http://www.amqp.org/>
-*/
-package amqp
-
-// #cgo LDFLAGS: -lqpid-proton
-import "C"
-
-// This file is just for
N_SYMBOL:
- return "symbol"
- case C.PN_DESCRIBED:
- return "described"
- case C.PN_ARRAY:
- return "array"
- case C.PN_LIST:
- return "list"
- case C.PN_MAP:
- return "map"
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/7b880b88/proton-c/bindings/go/pkg/linux_amd64/qpid.apache.org/proton/go/messaging.a
--
diff --git
a/proton-c/bindings/go/pkg/linux_amd64/qpid.apache.org/proton/go/messaging.a
"esc:0x0") Hostname () (? string)
+ func (@"".c·2 @"".Connection "esc:0x0") IsNil () (? bool) { return
@"".c·2.@"".pn == nil }
+ func (@"".c·2 @"".Connection "esc:0x0") LinkHead (@
"esc:0x0") Hostname () (? string)
+ func (@"".c·2 @"".Connection "esc:0x0") IsNil () (? bool) { return
@"".c·2.@"".pn == nil }
+ func (@"".c·2 @"".Connection "esc:0x0") LinkHead (@
NO-JIRA: remove jython2.5 compat code
Project: http://git-wip-us.apache.org/repos/asf/qpid-proton/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-proton/commit/b2f2fcd9
Tree: http://git-wip-us.apache.org/repos/asf/qpid-proton/tree/b2f2fcd9
Diff: http://git-wip-us.apache.org/repos/asf/qpi
NO-JIRA: Handler tests
Project: http://git-wip-us.apache.org/repos/asf/qpid-proton/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-proton/commit/ef36bd67
Tree: http://git-wip-us.apache.org/repos/asf/qpid-proton/tree/ef36bd67
Diff: http://git-wip-us.apache.org/repos/asf/qpid-proton/diff/e
PROTON-964: integrate proton-j redispatch with python
Project: http://git-wip-us.apache.org/repos/asf/qpid-proton/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-proton/commit/69fa53ba
Tree: http://git-wip-us.apache.org/repos/asf/qpid-proton/tree/69fa53ba
Diff: http://git-wip-us.apache.o
te low-level control of the underlying proton C engine.
-
-AMQP is an open standard for inter-operable message exchange, see
<http://www.amqp.org/>
-*/
-package amqp
-
-// #cgo LDFLAGS: -lqpid-proton
-import "C"
-
-// This file is just for the package comment.
-
-// FIXME aconway 201
-}
-
-// cHandler wraps a C pn_handler_t
-type cHandler struct {
- pn *C.pn_handler_t
-}
-
-func (h cHandler) HandleEvent(e Event) error {
- C.pn_handler_dispatch(h.pn, e.pn, C.pn_event_type(e.pn))
- return nil // FIXME aconway 2015-03-31: error handling
-}
-
-// MessagingHand
erlying proton C engine.
+
+AMQP is an open standard for inter-operable message exchange, see
<http://www.amqp.org/>
+*/
+package amqp
+
+// #cgo LDFLAGS: -lqpid-proton
+import "C"
+
+// This file is just for
if context == linkPump {
+ if context == nil {
+ log.Fatal("pop in nil context")
+ }
+ link.Send(message) // link is in the current pump, safe
to call Send() direct
+ } e
txt
--
diff --git a/examples/go/CMakeLists.txt b/examples/go/CMakeLists.txt
index 464ed7c..873180d 100644
--- a/examples/go/CMakeLists.txt
+++ b/examples/go/CMakeLists.txt
@@ -17,13 +17,21 @@
# under the License.
#
-# FIXME aconway 2015
-}
-
-// cHandler wraps a C pn_handler_t
-type cHandler struct {
- pn *C.pn_handler_t
-}
-
-func (h cHandler) HandleEvent(e Event) error {
- C.pn_handler_dispatch(h.pn, e.pn, C.pn_event_type(e.pn))
- return nil // FIXME aconway 2015-03-31: error handling
-}
-
-// MessagingHand
ying proton C engine.
+
+AMQP is an open standard for inter-operable message exchange, see
<http://www.amqp.org/>
+*/
+package amqp
+
+// #cgo LDFLAGS: -lqpid-proton
+import "C"
+
+// This file is just for the package comment.
+
+// FIXME aconway 2015-04-28: need to re-organize the p
"esc:0x0") Hostname () (? string)
- func (@"".c·2 @"".Connection "esc:0x0") IsNil () (? bool) { return
@"".c·2.@"".pn == nil }
- func (@"".c·2 @"".Connection "esc:0x0") LinkHead (@
ing/handler.go
+++ /dev/null
@@ -1,70 +0,0 @@
-/*
-Licensed to the Apache Software Foundation (ASF) under one
-or more contributor license agreements. See the NOTICE file
-distributed with this work for additional information
-regarding copyright ownership. The ASF licenses this file
-to
tp://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing,
+# software distributed under the License is distributed on an
+# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+# KIND, either express or implied. See the License for the
+# specif
{
+ t.Error(err)
+ }
+}
+
+func TestMap(t *testing.T) {
+ d := NewDecoder(getReader("maps"))
+
+ // Generic map
+ var m Map
+ checkDecode(d, Map{"one": int32(1), "two": int32(2), "three":
int32(3)}, &m, t)
+
+ // Inter
te low-level control of the underlying proton C engine.
-
-AMQP is an open standard for inter-operable message exchange, see
<http://www.amqp.org/>
-*/
-package amqp
-
-// #cgo LDFLAGS: -lqpid-proton
-import "C"
-
-// This file is just for the package comment.
-
-// FIXME aconway 201
txt
--
diff --git a/examples/go/CMakeLists.txt b/examples/go/CMakeLists.txt
index 464ed7c..873180d 100644
--- a/examples/go/CMakeLists.txt
+++ b/examples/go/CMakeLists.txt
@@ -17,13 +17,21 @@
# under the License.
#
-# FIXME aconway 2
che.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing,
+# software distributed under the License is distributed on an
+# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+# KIND, either express or implied. See the License for the
+# specific lan
quot;esc:0x0") Hostname () (? string)
+ func (@"".c·2 @"".Connection "esc:0x0") IsNil () (? bool) { return
@"".c·2.@"".pn == nil }
+ func (@"".c·2 @"".Connection "esc:0x0") LinkHead (@&quo
quot;esc:0x0") Hostname () (? string)
- func (@"".c·2 @"".Connection "esc:0x0") IsNil () (? bool) { return
@"".c·2.@"".pn == nil }
- func (@"".c·2 @"".Connection "esc:0x0") LinkHead (@&quo
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/9276ae33/proton-c/bindings/go/pkg/linux_amd64/qpid.apache.org/proton/go/internal.a
--
diff --git
a/proton-c/bindings/go/pkg/linux_amd64/qpid.apache.org/proton/go/internal.a
(h cHandler) HandleEvent(e Event) error {
+ C.pn_handler_dispatch(h.pn, e.pn, C.pn_event_type(e.pn))
+ return nil // FIXME aconway 2015-03-31: error handling
+}
+
+// MessagingHandler provides an alternative interface to EventHandler.
+// it is easier to use for most applications that send and
il, "Receiver is not open: %s", r)
+ r.policy.Pre(r)
+ defer func() { r.policy.Post(r, err) }()
+ rmi, ok, timedout := timedReceive(r.buffer, timeout)
+ switch {
+ case timedout:
+ return ReceivedMessage{}, Timeout
+ case !ok:
+
PROTON-827: Update README to mention online documentation.
Project: http://git-wip-us.apache.org/repos/asf/qpid-proton/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-proton/commit/32487f0a
Tree: http://git-wip-us.apache.org/repos/asf/qpid-proton/tree/32487f0a
Diff: http://git-wip-us.apa
{
+ t.Error(err)
+ }
+}
+
+func TestMap(t *testing.T) {
+ d := NewDecoder(getReader("maps"))
+
+ // Generic map
+ var m Map
+ checkDecode(d, Map{"one": int32(1), "two": int32(2), "three":
int32(3)}, &m, t)
+
+ // Inter
)
+ func (@"reflect".v·2 @"reflect".Value "esc:0x2") UnsafeAddr () (?
uintptr)
+ func (@"reflect".v·2 @"reflect".Value) @"reflect".assignTo
(@"reflect".context·3 string "esc:0x0", @"reflect"
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/7b880b88/proton-c/bindings/go/pkg/linux_amd64/qpid.apache.org/proton/go/internal.a
--
diff --git
a/proton-c/bindings/go/pkg/linux_amd64/qpid.apache.org/proton/go/internal.a
PROTON-827: go binding: minor example cleanup.
Project: http://git-wip-us.apache.org/repos/asf/qpid-proton/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-proton/commit/d8129acb
Tree: http://git-wip-us.apache.org/repos/asf/qpid-proton/tree/d8129acb
Diff: http://git-wip-us.apache.org/repo
PROTON-827: Updated README, removed redundant "go" symlink
Project: http://git-wip-us.apache.org/repos/asf/qpid-proton/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-proton/commit/cb868e92
Tree: http://git-wip-us.apache.org/repos/asf/qpid-proton/tree/cb868e92
Diff: http://git-wip-us.apa
ing(data))
+ case C.PN_SYMBOL:
+ *v = Symbol(goString(C.pn_data_get_symbol(data)))
+ case C.PN_MAP:
+ m := make(Map)
+ get(data, &m)
+ *v = m // FIXME aconway 2015-03-13: avoid the copy?
+ case C.PN_LIST:
+ l := make(List, 0
amqp
-
-// #include
-// #include
-// #include
-import "C"
-
-import (
- "qpid.apache.org/proton/go/internal"
- "time"
- "unsafe"
-)
-
-// FIXME aconway 2015-04-28: Do we need the interface or can we just export
the struct?
-
-// Messag
t exported fields to configure the connection before calling
+// Connection.Open()
+//
+type Connection struct {
+ // Server = true means a the connection will do automatic protocol
detection.
+ Server bool
+
+ // FIXME aconway 2015-04-17: Other parameters to set up SSL, SASL
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/7b880b88/proton-c/bindings/go/src/qpid.apache.org/proton/wrappers_gen.go
--
diff --git a/proton-c/bindings/go/src/qpid.apache.org/proton/wrappers_gen.go
b/proton-c/bindings/g
ll
+++ b/proton-c/bindings/go/src/qpid.apache.org/proton/go/amqp/doc.go
@@ -0,0 +1,40 @@
+/*
+Licensed to the Apache Software Foundation (ASF) under one
+or more contributor license agreements. See the NOTICE file
+distributed with this work for additional information
+regarding copyright owne
uint64)
- func (@"reflect".v·2 @"reflect".Value "esc:0x2") UnsafeAddr () (?
uintptr)
- func (@"reflect".v·2 @"reflect".Value) @"reflect".assignTo
(@"reflect".context·3 string "esc:0x0", @"reflect&quo
Author: aconway
Date: Mon Sep 28 21:30:50 2015
New Revision: 1705780
URL: http://svn.apache.org/viewvc?rev=1705780&view=rev
Log:
Corrected documentation links for godoc
Added:
qpid/site/docs/proton/amqp/
qpid/site/docs/proton/amqp/index.html
qpid/site/docs/proton/concurrent/
Author: aconway
Date: Mon Sep 28 21:31:42 2015
New Revision: 1705781
URL: http://svn.apache.org/viewvc?rev=1705781&view=rev
Log:
Corrected documentation links for godoc
Modified:
qpid/site/docs/proton/amqp/index.html
qpid/site/docs/proton/concurrent/index.html
qpid/site/docs/pr
Repository: qpid-proton
Updated Branches:
refs/heads/go1 [deleted] f5c9284c9
-
To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org
For additional commands, e-mail: commits-h...@qpid.apache.org
Repository: qpid-proton
Updated Branches:
refs/heads/master 000e02ae9 -> 8154edf9c
NO-JIRA: Minor update to memory_management.md
Project: http://git-wip-us.apache.org/repos/asf/qpid-proton/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-proton/commit/8154edf9
Tree: http://git-wip-us.
Repository: qpid-proton
Updated Branches:
refs/heads/go1 [created] e57c2a524
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/e57c2a52/proton-j/tasks/src/org/apache/qpid/tasks/Map.java
--
diff --git a/proton-j/tasks/src/
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/e57c2a52/proton-c/include/proton/value.h
--
diff --git a/proton-c/include/proton/value.h b/proton-c/include/proton/value.h
deleted file mode 100644
index c47fe83..000
---
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/e57c2a52/proton-j/engine/src/org/apache/qpid/proton/engine/impl/TransportImpl.java
--
diff --git
a/proton-j/engine/src/org/apache/qpid/proton/engine/impl/TransportImpl.java
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/e57c2a52/proton-c/src/security.xml
--
diff --git a/proton-c/src/security.xml b/proton-c/src/security.xml
deleted file mode 100644
index c6ac018..000
--- a/proton-c/src/sec
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/e57c2a52/proton-j/engine/src/org/apache/qpid/proton/engine/impl/ArraySequence.java
--
diff --git
a/proton-j/engine/src/org/apache/qpid/proton/engine/impl/ArraySequence.java
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/e57c2a52/proton-j/codec/src/org/apache/qpid/proton/type/Decimal128.java
--
diff --git a/proton-j/codec/src/org/apache/qpid/proton/type/Decimal128.java
b/proton-j/codec/src/or
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/e57c2a52/proton-j/codec/src/org/apache/qpid/proton/codec/AbstractPrimitiveType.java
--
diff --git
a/proton-j/codec/src/org/apache/qpid/proton/codec/AbstractPrimitiveType.java
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/e57c2a52/proton-j/codec/src/org/apache/qpid/proton/codec/DecoderImpl.java
--
diff --git a/proton-j/codec/src/org/apache/qpid/proton/codec/DecoderImpl.java
b/proton-j/codec/sr
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/e57c2a52/proton-j/codec/src/org/apache/qpid/proton/type/messaging/Received.java
--
diff --git
a/proton-j/codec/src/org/apache/qpid/proton/type/messaging/Received.java
b/prot
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/e57c2a52/proton-j/codec/src/org/apache/qpid/proton/type/transport/SessionError.java
--
diff --git
a/proton-j/codec/src/org/apache/qpid/proton/type/transport/SessionError.java
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/e57c2a52/proton-c/src/engine/engine.c
--
diff --git a/proton-c/src/engine/engine.c b/proton-c/src/engine/engine.c
deleted file mode 100644
index 8ec43d5..000
--- a/proton-
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/e57c2a52/proton-j/codec/src/org/apache/qpid/proton/codec/ListType.java
--
diff --git a/proton-j/codec/src/org/apache/qpid/proton/codec/ListType.java
b/proton-j/codec/src/org/
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/e57c2a52/proton-j/codec/src/org/apache/qpid/proton/type/transaction/TransactionalState.java
--
diff --git
a/proton-j/codec/src/org/apache/qpid/proton/type/transaction/Transac
Empty go1 branch.
Project: http://git-wip-us.apache.org/repos/asf/qpid-proton/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-proton/commit/e57c2a52
Tree: http://git-wip-us.apache.org/repos/asf/qpid-proton/tree/e57c2a52
Diff: http://git-wip-us.apache.org/repos/asf/qpid-proton/diff/e57c2a
Added: qpid/site/input/releases/qpid-dispatch-master/book/schema.html.in
URL:
http://svn.apache.org/viewvc/qpid/site/input/releases/qpid-dispatch-master/book/schema.html.in?rev=1705904&view=auto
==
--- qpid/site/input/rele
Added: qpid/site/input/releases/qpid-dispatch-master/book/addressing.html.in
URL:
http://svn.apache.org/viewvc/qpid/site/input/releases/qpid-dispatch-master/book/addressing.html.in?rev=1705904&view=auto
==
--- qpid/site/in
Added: qpid/site/docs/releases/qpid-dispatch-master/book/tools.html
URL:
http://svn.apache.org/viewvc/qpid/site/docs/releases/qpid-dispatch-master/book/tools.html?rev=1705904&view=auto
==
--- qpid/site/docs/releases/qpid-d
Added: qpid/site/docs/releases/qpid-dispatch-master/book/introduction.html
URL:
http://svn.apache.org/viewvc/qpid/site/docs/releases/qpid-dispatch-master/book/introduction.html?rev=1705904&view=auto
==
--- qpid/site/docs/r
Added: qpid/site/input/releases/qpid-dispatch-master/man/qdrouterd.html.in
URL:
http://svn.apache.org/viewvc/qpid/site/input/releases/qpid-dispatch-master/man/qdrouterd.html.in?rev=1705904&view=auto
==
--- qpid/site/input/
Author: aconway
Date: Tue Sep 29 18:03:12 2015
New Revision: 1705904
URL: http://svn.apache.org/viewvc?rev=1705904&view=rev
Log:
Update dispatch master release page for git, fix paths in dispatch man pages.
Added:
qpid/site/docs/releases/qpid-dispatch-master/
qpid/site/docs/releases/
r) {
@@ -129,18 +147,20 @@ func (c *connection) Disconnect(err error) {
}
}
-// FIXME aconway 2015-09-24: needed?
func (c *connection) closed(err error) {
// Call from another goroutine to initiate close without deadlock.
go c.Close(err)
}
-func (c *connection) New
lt))
+ default:
+ return buf[:len], nil
+ }
+ }
+ return encodeGrow(buffer, encode)
+}
+
+// TODO aconway 2015-09-14: Multi-section messages.
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/478ba4ea/proton-c/bindings/go/src/qpid.
lid consumer, no source address: %s", sender)
- return
- }
- q := b.queues.Get(qname)
- for {
- m := <-q.Pop
- if m == nil {
- break
- }
- if sm, err := send
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/478ba4ea/proton-c/bindings/go/src/qpid.apache.org/proton/amqp/unmarshal.go
--
diff --git a/proton-c/bindings/go/src/qpid.apache.org/proton/amqp/unmarshal.go
b/proton-c/bindin
Repository: qpid-proton
Updated Branches:
refs/heads/master 2789615a1 -> 478ba4ea1
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/478ba4ea/proton-c/bindings/go/src/qpid.apache.org/proton/engine.go
--
diff --git a/proto
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/478ba4ea/proton-c/bindings/go/src/qpid.apache.org/electron/receiver.go
--
diff --git a/proton-c/bindings/go/src/qpid.apache.org/electron/receiver.go
b/proton-c/bindings/go/sr
Repository: qpid-proton
Updated Branches:
refs/heads/master 2e8995f3b -> 1ae893efe
NO-JIRA: Added go-get repo update script
Project: http://git-wip-us.apache.org/repos/asf/qpid-proton/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-proton/commit/1ae893ef
Tree: http://git-wip-us.apach
Repository: qpid-proton
Updated Branches:
refs/heads/master 4f6d9fb53 -> 8112f5f09
NO-JIRA: c++ binding: remove incorrect messaging_handler events.
Removed on_abort, on_commit, on_fetch and on_quit. They are not messaging
events,
they are example application events from the python tx_recv_int
g_event.hpp
+++ b/proton-c/bindings/cpp/include/proton/messaging_event.hpp
@@ -37,6 +37,8 @@ class messaging_event : public proton_event
{
public:
+std::string name() const;
+
// TODO aconway 2015-07-16: document meaning of each event type.
/** Event types for a messaging_h
-class handler;
-class container;
-class connection;
-class message;
-
-/** An event for the proton::messaging_handler */
-class messaging_event : public proton_event
-{
- public:
-
-std::string name() const;
-
-// TODO aconway 2015-07-16: document meaning of each event type.
-
-/** Event
Repository: qpid-proton
Updated Branches:
refs/heads/master bd698eeba -> 6859fa307
NO-JIRA: Travis config: don't run build if cmake fails, don't run tests if
build fails.
Project: http://git-wip-us.apache.org/repos/asf/qpid-proton/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-prot
it a/proton-c/bindings/go/CMakeLists.txt
b/proton-c/bindings/go/CMakeLists.txt
index d24bf2e..11a3b78 100644
--- a/proton-c/bindings/go/CMakeLists.txt
+++ b/proton-c/bindings/go/CMakeLists.txt
@@ -17,52 +17,54 @@
# under the License.
#
+# Go version
+execute_process(COMMAND ${GO_EXE}
401 - 500 of 1695 matches
Mail list logo