Skip to content
This repository was archived by the owner on Nov 1, 2023. It is now read-only.

Commit 3370c3d

Browse files
authored
Replace queue_node_heatbeat (#1875)
* repalce queue_node_heatbeat * Changing the name of the input queue * [testing] hard code deployment of -net function * explicitly disable other C# functions
1 parent c07a908 commit 3370c3d

File tree

7 files changed

+7
-7
lines changed

7 files changed

+7
-7
lines changed

src/ApiService/ApiService/QueueFileChanges.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,7 @@ public QueueFileChanges(ILogTracer log, IStorage storage, INotificationOperation
2121
_notificationOperations = notificationOperations;
2222
}
2323

24-
[Function("QueueFileChanges")]
24+
//[Function("QueueFileChanges")]
2525
public async Async.Task Run(
2626
[QueueTrigger("file-changes-refactored", Connection = "AzureWebJobsStorage")] string msg,
2727
int dequeueCount) {

src/ApiService/ApiService/QueueNodeHearbeat.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,7 @@ public QueueNodeHearbeat(ILogTracer log, IOnefuzzContext context) {
1616
}
1717

1818
[Function("QueueNodeHearbeat")]
19-
public async Async.Task Run([QueueTrigger("myqueue-items", Connection = "AzureWebJobsStorage")] string msg) {
19+
public async Async.Task Run([QueueTrigger("node-heartbeat", Connection = "AzureWebJobsStorage")] string msg) {
2020
_log.Info($"heartbeat: {msg}");
2121
var nodes = _context.NodeOperations;
2222
var events = _context.Events;

src/ApiService/ApiService/QueueProxyHeartbeat.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@ public QueueProxyHearbeat(ILogTracer log, IProxyOperations proxy) {
1414
_proxy = proxy;
1515
}
1616

17-
[Function("QueueProxyHearbeat")]
17+
//[Function("QueueProxyHearbeat")]
1818
public async Async.Task Run([QueueTrigger("myqueue-items", Connection = "AzureWebJobsStorage")] string msg) {
1919
_log.Info($"heartbeat: {msg}");
2020

src/ApiService/ApiService/QueueSignalREvents.cs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -9,8 +9,8 @@ public QueueSignalREvents(ILogTracerFactory loggerFactory) {
99
_loggerFactory = loggerFactory;
1010
}
1111

12-
[Function("QueueSignalREvents")]
13-
[SignalROutput(HubName = "dashboard")]
12+
//[Function("QueueSignalREvents")]
13+
//[SignalROutput(HubName = "dashboard")]
1414
public static string Run(
1515
[QueueTrigger("signalr-events-refactored", Connection = "AzureWebJobsStorage")] string msg) {
1616
return msg;

src/ApiService/ApiService/QueueTaskHearbeat.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -18,7 +18,7 @@ public QueueTaskHearbeat(ILoggerFactory loggerFactory, ITaskOperations tasks, IE
1818
_events = events;
1919
}
2020

21-
[Function("QueueTaskHearbeat")]
21+
//[Function("QueueTaskHearbeat")]
2222
public async Async.Task Run([QueueTrigger("myqueue-items2", Connection = "AzureWebJobsStorage")] string msg) {
2323
_logger.LogInformation($"heartbeat: {msg}");
2424

src/ApiService/ApiService/QueueWebhooks.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -12,7 +12,7 @@ public QueueWebhooks(ILogTracer log, IWebhookMessageLogOperations webhookMessage
1212
_webhookMessageLog = webhookMessageLog;
1313
}
1414

15-
[Function("QueueWebhooks")]
15+
//[Function("QueueWebhooks")]
1616
public async Async.Task Run([QueueTrigger("myqueue-items", Connection = "AzureWebJobsStorage")] string msg) {
1717

1818
_log.Info($"Webhook Message Queued: {msg}");

0 commit comments

Comments
 (0)