Граф коммитов

26 Коммитов

Автор SHA1 Сообщение Дата
Joel Hendrix e738348ca5
Update amqp and other dependencies (#153)
* update dependencies

switched pack.ag/amqp to github.com/Azure/go-amqp
updated azure-amqp-common-go to v3
update Go SDK dependencies to latest versions

* fix test output, ignore .vscode directory

* update release notes and version info
2019-12-16 09:58:02 -08:00
David Justice 2d7ef1757e
move to azure-amqp-common-v2 2019-06-06 08:49:02 -07:00
David Justice bb3abf8055
add websocket support 2019-04-24 17:43:55 -07:00
McGrady Chen (RD-CN) 330db51df7 Add concurrent receive example 2019-04-13 22:23:29 +08:00
McGrady Chen (RD-CN) 9fb31b39cb Revert "Add concurrent receive messages example"
This reverts commit 294a0ef4a9.
2019-04-13 22:02:12 +08:00
McGrady Chen (RD-CN) 294a0ef4a9 Add concurrent receive messages example 2019-04-13 12:56:32 +08:00
David Justice e4fe45999d
fix queue get example 2019-03-12 16:13:15 -07:00
David Justice 98bd822ffe
rename groupID to sessionID 2018-12-07 13:28:55 -08:00
David Justice 74f8c2c4a7
refactor sessions and open receiver and sender to public 2018-11-30 13:51:11 -08:00
David Justice e4ed844e43
change handler to allow for failed dispositions 2018-11-28 11:35:06 -08:00
David Justice 5c0fda8555
fix session filters and get tests passing 2018-11-27 14:57:42 -08:00
Martin Strobel 3884a90a86 Adding the ability to cancel scheduled messges 2018-11-02 14:37:07 -07:00
Martin Strobel c03b0ce8d4 Adding Queue.ScheduleAt 2018-10-30 15:52:49 -07:00
Martin Strobel 5a1874ad16 Merge branch 'sessions' 2018-10-19 15:15:08 -07:00
Martin Strobel 375f205be3 Removing ref to strings.Builder, replacing with bytes.Buffer
This should fix the Go 1.9 build.
2018-10-19 14:54:04 -07:00
Martin Strobel 31feff3903 Adding Queue examples that are minimized just to demonstrate a single operation. 2018-10-19 14:25:07 -07:00
Martin Strobel 79a31768c5 Now the receiver can ask the broker to choose a session, instead of forcing the receiver to. 2018-10-18 16:12:06 -07:00
Martin Strobel ccdc1029b3 SessionID parameters for 'ReceiveSessions' and 'ReceiveOneSession' are now pointers. Also renaming Renew to RenewLock.
Making SessionID a pointer allows it to be nilable, which in turn changes the semantics around which messages the server will
send a particular client.
2018-10-16 15:22:58 -07:00
Martin Strobel 1bd35f2be2 Receiving a specified session now works. 2018-10-02 13:56:00 -07:00
Davor Kapsa 4f5f9f3c3f add error check 2018-10-01 10:23:03 -07:00
Martin Strobel 0f03488e7b Updating the SessionHandler contract to take a whole MessageSession instance instead of just a SessionID 2018-09-28 17:37:31 -07:00
Martin Strobel a980ffe479 Adding ReceiveSessions example to demonstrate the desired experience.
At the moment, none of this is implemented, but this is how I want it to feel to begin listening to a queue for whole sessions to process.
2018-09-28 11:19:53 -07:00
Martin Strobel 234d8a44f8 Changing Receive and ReceiveOne to be blocking calls.
Fundamentally, I'm making this change because of advise that @bketelsen gave me. To paraphrase him, "never design your API to have non-blocking calls. It's not the Go way." However, to back that up, it's been something that bit me several times while I was working with this Service Bus library.
2018-09-26 12:18:05 -07:00
Martin Strobel 649e392a9c Having each sample target separate SB Queues.
When a test was partially executed (because of interruption) this was
leading to interference with other examples. The additionial
independence could also allow for future parallelization.
2018-09-13 10:33:10 -07:00
Martin Strobel 182d224f0b Refactoring Environment Variable references. 2018-09-12 12:53:44 -07:00
Martin Strobel be8f9db4d1
Making Examples Executable Tests (#27)
* Moving scheduledMessage example to increase visibility

* Removing reference to scheduledMessage example in README

* Moving helloworld example

* Fixing build errors after rebase

* Moving opentracing example

* Fix opentracing/readme.md execution instructions

* Removing extraneous reference to example that has been moved

* Updating SendReceiveScheduledMessage timeline.

Previously, the message was scheduled to be delivered 15 seconds in the future. Service Bus has a schedule granularity more along the lines of a 1-minute window. For that reason, I update this test to take 3 minutes. From there, I had to update some of the other timeout logic in the test harness to allow a test that took more than 1 minute.

* Removing unused const

* Removing examples section from Makefile now that they are incorporated as tests
2018-08-07 17:48:41 -07:00