Advertisement
Guest User

Untitled

a guest
Feb 27th, 2017
90
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 2.24 KB | None | 0 0
  1. public CallSettings GetPullSetting()
  2. {
  3. CallTiming timing = CallTiming.FromRetry(new RetrySettings(
  4. retryBackoff: new BackoffSettings(new TimeSpan(0, 0, 0, 0, 50), new TimeSpan(0, 0, 5), 1),
  5. timeoutBackoff: new BackoffSettings(new TimeSpan(0, 0, 0, 18, 0), new TimeSpan(0, 0, 20), 1),
  6. totalExpiration: Google.Api.Gax.Expiration.FromTimeout(TimeSpan.FromMilliseconds(600000))));
  7.  
  8. return CallSettings.FromCallTiming(timing);
  9. }
  10.  
  11. public void PullTest()
  12. {
  13. var cont = true;
  14. SubscriberSettings settings = new SubscriberSettings()
  15. {
  16. PullSettings = GetPullSetting()
  17. };
  18. SubscriberClient subscriberClient = SubscriberClient.Create(settings: settings);
  19. var subscriberName = new SubscriptionName("project-name", "subscription-name");
  20. while (cont)
  21. {
  22. try
  23. {
  24. PullResponse response = subscriberClient.Pull(subscriberName, returnImmediately: false, maxMessages: 1);
  25. System.Diagnostics.Trace.WriteLine(">>>>>> " + DateTime.Now.ToString());
  26. System.Diagnostics.Trace.WriteLine(">>>>>> " + "Job Recieved" + response.ReceivedMessages.ToList().FirstOrDefault());
  27. subscriberClient.Acknowledge(subscriberName, new List<string>() { response.ReceivedMessages.ToList().FirstOrDefault().AckId });
  28. }
  29. catch (Exception ex)
  30. {
  31. System.Diagnostics.Trace.WriteLine(">>>>>> " + DateTime.Now.ToString());
  32. System.Diagnostics.Trace.WriteLine(">>>>>> " + ex.Message);
  33. }
  34. }
  35. }
  36.  
  37. public CallSettings GetPullSetting()
  38. {
  39. CallTiming timing = CallTiming.FromRetry(new RetrySettings(
  40. retryBackoff: new BackoffSettings(new TimeSpan(0, 0, 0, 0, 50), new TimeSpan(0, 0, 5), 1),
  41. timeoutBackoff: new BackoffSettings(new TimeSpan(0, 0, 0, 18, 0), new TimeSpan(0, 0, 20), 1),
  42. totalExpiration: Google.Api.Gax.Expiration.FromTimeout(TimeSpan.FromMilliseconds(600000))));
  43.  
  44. return CallSettings.FromCallTiming(timing);
  45. }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement