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

399 Коммитов

Автор SHA1 Сообщение Дата
Serkant Karaca acdebbb23f Web sockets support (#177)
* Cleaning things up for websockets support.

* Adding AMQP web sockets support

* Moving to AMQP 2.1.0

* Fixing build failure.

* Remove secrets

* Fix SasKey remove issue in unit test.
2017-08-10 11:51:38 -07:00
Serkant Karaca 9824854664 Fix appveyor.yml (#192)
* Fix appveyor.yml

* Add build log to build.ps1

* .

* .

* .

* .

* .

* Appveyor account changes in readme.md
2017-08-09 16:57:05 -07:00
Serkant Karaca bf935d2bf9 Fix lease-lost decision logic (#179)
* Provide inner exception's message as LeaseLostException's message.

* Fix the lease-lost decision logic.
2017-07-28 16:26:38 -07:00
maxbrodin fe76a6aa05 Using ConfigureAwait(false) to avoid context restoration (#182) 2017-07-28 16:25:40 -07:00
Serkant Karaca 51ca8ab0c6 Adding shared access signature support. (#174)
* Adding shared access signature support.
* Fixing a comment typo.
* Reducing the number of clients to 4 in SmallReceiveTimeout unit test.
2017-06-22 12:48:08 -07:00
John Taubensee 4f18a47a7d Adding API documentation (#168) 2017-05-31 15:10:45 -07:00
John Taubensee 06381f8aad Appveyor and unit test updates (#166) 2017-05-26 17:25:13 -07:00
Serkant Karaca 1b3abcee0e Fix audience on the ActiveClientLink (#164) 2017-05-23 13:14:35 -07:00
John Taubensee e5fa354761 Update project to VS 2017 (#158) 2017-05-02 15:29:56 -07:00
jtaubensee b29ab0b70e Updating readme with sample location 2017-05-01 09:00:10 -07:00
Serkant Karaca dea8ad8292 Batch event data API (#157)
* Draft

* EvetDataBatch first iteration.

* Implementing IDisposable on EventData and EventDataBatch

* Removing EventHubSendBatchMismatchPartitionKey from resources.

* .

* Remove unused NullString constant

* Calling MaxMessageSize() instead of MaxMessageSize property.
2017-04-14 18:00:06 -07:00
jtaubensee cd5c598822 Setting appveyor build to only build master/dev branches. 2017-04-11 15:26:16 -07:00
Serkant Karaca 835b1ff3ca Allow at least 60 seconds for AMQP session create. (#154)
* Allow at least AmqpMinimumOpenSessionTimeoutInSeconds seconds to open the session.

* refactor

* Fixing unit tests to support timeout change.
2017-04-10 17:25:05 -07:00
John Taubensee 72aef4a365 Codecov (#155)
* Updated Xunit refs, set assemblies to run in order, added codecov step to build

* Adding an additional filter

* ran same tests twice

* made variables a little more clear

* Missed another variable for build

* Adding codecov badges

* Adding back net46 test runs
2017-04-10 14:22:48 -07:00
Serkant Karaca fc145dd4d7 Slimming down AsyncLock by removing unnecessary checks and calls. (#153) 2017-04-06 12:57:50 -07:00
jtaubensee a24ef4950f Updating EPH NuGet package description 2017-04-05 13:05:28 -07:00
jtaubensee fb98067d88 Updating NuGet package descriptions 2017-04-05 13:04:50 -07:00
Serkant Karaca d4ca17596f Bumping up dependent SDK to latest - 3131. (#150) 2017-03-24 12:14:33 -07:00
Serkant Karaca 1863766426 Bumping up the Storage version to 8.1.1 (#149) 2017-03-22 17:53:33 -07:00
John Taubensee 4342346f38 Merge branch 'master' into dev 2017-03-22 13:54:19 -07:00
John Taubensee a7db6e7f94 Update global.json (#147)
Specifying .net core version for Appveyor build
2017-03-22 12:50:27 -07:00
Serkant Karaca c166e64b32 Avoid TaskCancelledException from ContinueWith when blob call fails due to lease lost. (#145) 2017-03-15 15:07:30 -07:00
Serkant Karaca 79a9931852 EPH lease manager and checkpointing fixes and improvements (#117)
* Fixing build break introduced with preview check-in.

* Here is the list of the changes:
+ Moving Offset and SequenceNumbre to base class Lease.cs
+ AzureStorageCheckpointLeaseManager.cs to stop downloading lease at every checkpoint call. This was causing 2 hosts operating on the same lease for a while.
+ Set MaximumExecutionTime on renewRequestOptions used while renewing storage lease.
+ Throw LeaseLostException when lease is lost on operations like Renew and Update.
+ Updating interface ICheckpointManager to accept Lease while updating checkpoint.
+ Some Linq improvements at lease steal and balancing logics.
+ Updating multiple-hosts unit test to validate load balancing.

* Set PartitionContext's SequenceNumber and Offset only before delivering the messages to the handler.

* CheckpointAsync(EventData eventData) should not allow checkpointing if the suplied eventData is ahead of processed batch.

* Add unit test to cover checkpointing messages in the middle of a batch.

* Marking ICheckpointManager.UpdateCheckpointAsync(Checkpoint checkpoint) as obsolute

* Fix: ReceiveHandler and PartitionPump should gracefully handle exceptions thrown at ProcessError callbacks.
Adding a CIT to cover error cases in EPH.

* HostShouldRecoverWhenProcessProcessEventsAsyncThrows unit test to unregister host at the end.

* Cancelling swallow and trace change in ReceiveHandlerProcessErrorAsync(Exception error)

* Remove unnecessary ExceptionHandled trace from EventSource.

* + Removing Obsolete signature from ICheckpointManager.
+ TaskContinuationOptions.OnlyOnRanToCompletion while persisting lease.

* Adding Obsolete ICheckpointManager.UpdateCheckpointAsync(Checkpoint checkpoint) back
2017-03-13 13:21:27 -07:00
Seth Manheim 82e418a7f6 Moving samples to the azure-event-hubs repo (#142)
* Moving samples to the azure-event-hubs repo

* Fixes
2017-03-07 15:07:38 -08:00
Serkant Karaca 9088ebde91 ProcessorHost to close on ReceiverDisconnectedException (#137)
* Update readme.md (#110)

Fixed broken links.

* Fault partition pump on ReceiverDisconnectedException only.
2017-03-07 11:10:57 -08:00
Serkant Karaca ffe1fefbce Remove lease object from LeaseLostException (#143)
* Remove Lease object from LeaseLostException

* Use partition id from context.
2017-03-06 09:16:35 -08:00
Serkant Karaca 8130c103ca Fix empty lease race issue (#141)
* Update readme.md (#110)

Fixed broken links.

* Handle race condition where downloaded empty-lease might be already LEASED by some other host.
2017-03-02 13:09:30 -08:00
Serkant Karaca 8f9958fe5a Remove ActiveClientManager from service client (#136)
* Update readme.md (#110)

Fixed broken links.

* Code cleanup: Removing ActiveLinkManager from AmqpServiceClient
2017-03-01 16:40:49 -08:00
Serkant Karaca 3187abda26 Unregister receive handler fix (#135)
* Update readme.md (#110)

Fixed broken links.

* Unregistering receive handler shouldn't generate OperationCanceledException

* Removing .Fork() comment
2017-03-01 13:34:32 -08:00
Serkant Karaca f4eab19935 Receive should not throw timeout exception (#130)
* Update readme.md (#110)

Fixed broken links.

* ReceiveAsync call should return NULL instead of throwing System.TimeoutException
2017-02-27 17:37:19 -08:00
Serkant Karaca f88469bda4 Receive handler should failfast on unhandled exception (#127)
* Update readme.md (#110)

Fixed broken links.

* ReceiveHandler should failfast when an unhandled exception detected.
Adding a unit test to cover error handling and recovery for EPH.

* Remove unintentional internal modifier.

* Trace receive handler exit w/ error.
2017-02-24 15:23:03 -08:00
Serkant Karaca 2ca2ee74e6 Amqp create link should honor time left (#128)
* Update readme.md (#110)

Fixed broken links.

* AmqpSender and AmqpReceiver should honor tile left while creating AMQP link.

* Remove unnecessary variable.
2017-02-24 12:38:39 -08:00
Serkant Karaca 9deb344c2d Fix invoke processor after receive timeout behavior (#124)
* Update readme.md (#110)

Fixed broken links.

* EPH to deliver Enumerable.Empty instead of NULL when EventProcessorOptions.InvokeProcessorAfterReceiveTimeout is set

* Small refactoring to honor positive check.
2017-02-21 15:02:46 -08:00
jtaubensee 808048d6e5 Keeping sample readmes in sync with docs.microsoft.com 2017-02-21 09:50:42 -08:00
Serkant Karaca 2c773e9df2 Bumping up EPH client version to 1.0.1 on dev branch (#118)
* Fixing build break introduced with preview check-in.

* Bumping up EPH client version to 1.0.1 on dev branch
2017-02-08 09:57:21 -08:00
Serkant Karaca cb160c3c07 Deliver receiver disconnected exception to client (#109)
* Fixing build break introduced with preview check-in.

* + PartitionPump to deliver ReceiverDisconnectedException to processor host.
+ Don't look for ReceiverDisconnectedException while creating the receiver since CreateReceiver doesn't throw it.

* Adding unit test covering ReceiverDisconnectedException handling due to higher epoch receiver.
2017-02-07 11:25:50 -08:00
jtaubensee 81f4b702fa Update readme.md (#110)
Fixed broken links.
2017-02-03 10:14:43 -08:00
Marcin Bazydlo a201266434 Update readme.md (#110)
Fixed broken links.
2017-02-03 10:10:48 -08:00
Serkant Karaca 7f4ea7715b Adding 2 new epoch unit tests (#108)
* Fixing build break introduced with preview check-in.

* Adding 2 new epoch receiver unit tests.
2017-02-02 15:51:33 -08:00
Serkant Karaca 542a5e1bd1 Bumping up client version to 1.0.1 (#107)
* Fixing build break introduced with preview check-in.

* Bumping up the client version to 1.0.1
2017-02-01 15:51:16 -08:00
John Taubensee 1cedfdec99 Merge pull request #106 from Azure/dev
1.0.0 Release
2017-02-01 13:57:26 -08:00
Serkant Karaca 50a54c4803 Bumping up client version to100 (#105)
* Fixing build break introduced with preview check-in.

* Bumping up client version to 1.0.0
2017-02-01 13:52:17 -08:00
jtaubensee 9d17ccb0c6 Added Appveyor dev build badge to readme 2017-02-01 12:13:49 -08:00
Serkant Karaca 6effde4cbc + Moving to Azure.AMQP 2.0.4 (#104)
+ Moving back to .Net451
+ Improving AMQP message convertor to rule out empty message case.
+ Adding message body validation to basic send/receive unit test.
2017-02-01 11:21:32 -08:00
Serkant Karaca 272fbfa357 Small change, allowing zero body length for batch sends as well. (#101)
* Fixing build break introduced with preview check-in.

* Default instinstantiation of application properties on EventData

* Correct handling of byte[0] payloads.

* Adding NULL body eventdata negative unit test.

* Async fix for new negative test.

* Allow zero length body in batch sends as well.
2017-01-27 09:48:12 -08:00
Serkant Karaca cad65f9e4e Instantiate application properties as part on EventData instantiation (#100)
* Fixing build break introduced with preview check-in.

* Default instinstantiation of application properties on EventData

* Correct handling of byte[0] payloads.

* Adding NULL body eventdata negative unit test.

* Async fix for new negative test.
2017-01-27 09:16:31 -08:00
jtaubensee 4779f82ee3 Updating sample readme names 2017-01-25 17:23:10 -08:00
Serkant Karaca c71b90b9f2 Moving net framework to 452 (#98)
* Fixing build break introduced with preview check-in.

* Moving .Net framework to 4.5.2

* ClientInfo fix.
2017-01-25 14:49:26 -08:00
Serkant Karaca 9264078704 Moving net framework to 452 (#97)
* Fixing build break introduced with preview check-in.

* Moving .Net framework to 4.5.2
2017-01-25 14:38:21 -08:00
Serkant Karaca b62f285ee2 Fixing build break introduced with preview check-in. (#96) 2017-01-25 11:13:50 -08:00