Skip to content

Commit

Permalink
TDLQ count
Browse files Browse the repository at this point in the history
  • Loading branch information
paolos authored and paolos committed Apr 20, 2017
1 parent a964d4a commit a8a0adc
Show file tree
Hide file tree
Showing 7 changed files with 670 additions and 845 deletions.
20 changes: 2 additions & 18 deletions App.config
View file
Original file line number Diff line number Diff line change
Expand Up @@ -16,22 +16,6 @@
<add key="CustomConnectionString" value="namespace=NAMESPACE;servicePath=;issuerName=owner;issuerSecret=XXXXXXXXXXXXXXXXXXXXXXXXXXXXXX=" />
<add key="ACSConnectionString" value="endpoint=sb://NAMESPACE.servicebus.windows.net/;sharedSecretIssuer=owner;sharedSecretValue=XXXXXXXXXXXXXXXXXXXXXXXXXXXXXX=" />
<add key="SASConnectionString" value="Endpoint=sb://NAMESPACE.servicebus.windows.net/;SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=XXXXXXXXXXXXXXXXXXXXXXXXXXXXXX=" />
<add key="BaboEastUS2" value="Endpoint=sb://baboeastus2.servicebus.windows.net/;SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=XUhT6IrqSyFJHsScCocEJSbahbVG0g8jv1abph6UCF4=" />
<add key="PaoloSalvatori" value="Endpoint=sb://paolosalvatori.servicebus.windows.net/;SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=yeZZL+AEWfa7c7o1S8kf02Dlpmr7x/Ne1lojs4+fXLo=" />
<add key="Baboland" value="namespace=baboland;servicePath=;issuerName=owner;issuerSecret=p8XV6QiRjunU2KgRZXfSRb4uGnqF6+JNBDq4NM09Ktc=" />
<add key="BabosBird" value="Endpoint=sb://babosbird.servicebus.windows.net/;SharedSecretIssuer=owner;SharedSecretValue=ORy3Nej43/vlsNrQxQeC5mqgg6ySPygrF79QKV4wSF0=" />
<add key="AngryBirds" value="Endpoint=sb://angrybirds.servicebus.windows.net/;SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=ptdVSSBL/NTpIKWJhL24zvNh4Qw6doYbLFKa5sNz48c=" />
<add key="USBabo" value="Endpoint=sb://usbabo.servicebus.windows.net/;SharedSecretIssuer=owner;SharedSecretValue=XlW+dQkS+Yon0EW0Cle0TqYvPYHbZHnsJMCpBCm7Tpc=" />
<add key="SouthBabo" value="Endpoint=sb://southbabo.servicebus.windows.net/;SharedSecretIssuer=owner;SharedSecretValue=WDafWhilRd6dJqU8RavjBwp8o5Lona7O6mKkHxKqZHc=;TransportType=Amqp" />
<add key="Tribble" value="Endpoint=sb://tribble.servicebus.windows.net/;SharedSecretIssuer=owner;SharedSecretValue=yPteZbk1dgJci5EGjS9Am2cXwxBA3xOUnezLzIJ9LYg=" />
<add key="UglyDolls" value="Endpoint=sb://uglydolls.servicebus.windows.net/;SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=o1RurzyDFZ9WY9314TaXjUrJ4FrZMcZSUzqrl3eJeiI=" />
<add key="IoTLand" value="Endpoint=sb://iotland.servicebus.windows.net/;SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=ewniN1cBNBi9I2WCYKGr6k/bSg1q5C25l04gCqixXJo=" />
<add key="EventHubs" value="Endpoint=sb://eventhubs.servicebus.windows.net/;SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=GyNaU6zBgrOAKuSLwKsyaqToZ4lXBBokTDDNb0s9sVs=" />
<add key="Emea-ServiceBus" value="Endpoint=sb://emea-servicebus.servicebus.windows.net/;SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=ugKBuKS8m7gRbyIpRs81K7x8MCeJB8atc8waaQSartA=" />
<add key="NewIoT" value="Endpoint=sb://newiot.servicebus.windows.net/;SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=ld4PhU5kAIWsPfU3SJL3Uyv5R4caOCsS/TvMjqDxIB4=" />
<add key="NorthEuropeEventHubs" value="Endpoint=sb://northeuropeeventshubs.servicebus.windows.net/;SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=bgdospHzGF+Ftf9/wY5Aslqex7mwDLcj+g6+kywEQ14=" />
<add key="BaboPremium" value="Endpoint=sb://babopremium.servicebus.windows.net/;SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=Yi7Xv0h9mP9yW0IHiSwc/XvTXZ7vZWlmzkjyzfUg04Q=" />
<add key="MyNotificationHubs" value="Endpoint=sb://mynotificationhubs.servicebus.windows.net/;SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=28RxUpux2r8eZnwJbxdlxHmpO19vPxshGF2OX6UOf2U=" />
</serviceBusNamespaces>
<brokeredMessageInspectors>
<add key="LogBrokeredMessageInspector" value="Microsoft.Azure.ServiceBusExplorer.Helpers.LogBrokeredMessageInspector,ServiceBusExplorer"/>
Expand Down Expand Up @@ -71,8 +55,8 @@
<add key="senderThinkTime" value="500"/>
<add key="receiverThinkTime" value="500"/>
<add key="monitorRefreshInterval" value="30"/>
<add key="subscriptionId" value="1a45a694-ae23-4650-9774-89a571c462f6"/>
<add key="certificateThumbprint" value="4AEA75244040D33F6E51ACD64594CB0727302507"/>
<add key="subscriptionId" value="XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX"/>
<add key="certificateThumbprint" value="YYYYYYYYYYYYYYYYYYYYYYYYYYYYYYYYYYYY"/>
<add key="messageDeferProvider" value="Microsoft.Azure.ServiceBusExplorer.InMemoryMessageDeferProvider,ServiceBusExplorer"/>
<add key="Microsoft.ServiceBus.X509RevocationMode" value="NoCheck"/>
<add key="ClientSettingsProvider.ServiceUri" value=""/>
Expand Down
2 changes: 1 addition & 1 deletion Controls/HandleQueueControl.Designer.cs
View file

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

85 changes: 38 additions & 47 deletions Controls/HandleQueueControl.cs
View file
Original file line number Diff line number Diff line change
Expand Up @@ -606,9 +606,9 @@ public void GetMessageSessions()
{
try
{
ControlHelper.SuspendDrawing(mainTabControl);
mainTabControl.SuspendDrawing();
mainTabControl.SuspendLayout();
ControlHelper.SuspendDrawing(tabPageSessions);
tabPageSessions.SuspendDrawing();
tabPageSessions.SuspendLayout();

var queueClient = serviceBusHelper.MessagingFactory.CreateQueueClient(queueDescription.Path,
Expand Down Expand Up @@ -653,9 +653,9 @@ public void GetMessageSessions()
finally
{
mainTabControl.ResumeLayout();
ControlHelper.ResumeDrawing(mainTabControl);
mainTabControl.ResumeDrawing();
tabPageSessions.ResumeLayout();
ControlHelper.ResumeDrawing(tabPageSessions);
tabPageSessions.ResumeDrawing();
Cursor.Current = Cursors.Default;
}
}
Expand Down Expand Up @@ -1355,8 +1355,8 @@ private void InitializeData()
btnChangeStatus.Visible = true;
btnMessages.Visible = true;
btnSessions.Visible = queueDescription.RequiresSession;
btnMessages.Visible = string.IsNullOrWhiteSpace(queueDescription.ForwardTo);
btnDeadletter.Visible = string.IsNullOrWhiteSpace(queueDescription.ForwardDeadLetteredMessagesTo);
//btnMessages.Visible = string.IsNullOrWhiteSpace(queueDescription.ForwardTo);
//btnDeadletter.Visible = string.IsNullOrWhiteSpace(queueDescription.ForwardDeadLetteredMessagesTo);

if (btnMessages.Visible && !btnSessions.Visible && !buttonsMoved)
{
Expand Down Expand Up @@ -1435,7 +1435,7 @@ private void InitializeData()
},
new[] {MessageCount, queueDescription.MessageCount.ToString("N0", CultureInfo.CurrentCulture)}
});

propertyListView.Items.Clear();
foreach (var array in propertyList)
{
Expand Down Expand Up @@ -1578,9 +1578,9 @@ private void GetMessages(bool peek, bool all, int count, IBrokeredMessageInspect
{
try
{
ControlHelper.SuspendDrawing(mainTabControl);
mainTabControl.SuspendDrawing();
mainTabControl.SuspendLayout();
ControlHelper.SuspendDrawing(tabPageMessages);
tabPageMessages.SuspendDrawing();
tabPageMessages.SuspendLayout();

Cursor.Current = Cursors.WaitCursor;
Expand Down Expand Up @@ -1636,7 +1636,7 @@ private void GetMessages(bool peek, bool all, int count, IBrokeredMessageInspect
: count - totalRetrieved,
TimeSpan.FromSeconds(MainForm.SingletonMainForm.ReceiveTimeout));
var enumerable = messages as BrokeredMessage[] ?? messages.ToArray();
retrieved = enumerable.Count();
retrieved = enumerable.Length;
if (retrieved == 0)
{
continue;
Expand Down Expand Up @@ -1667,10 +1667,7 @@ private void GetMessages(bool peek, bool all, int count, IBrokeredMessageInspect

if (!peek)
{
if (OnRefresh != null)
{
OnRefresh();
}
OnRefresh?.Invoke();
}
if (mainTabControl.TabPages[MessagesTabPage] == null)
{
Expand Down Expand Up @@ -1698,9 +1695,9 @@ private void GetMessages(bool peek, bool all, int count, IBrokeredMessageInspect
finally
{
mainTabControl.ResumeLayout();
ControlHelper.ResumeDrawing(mainTabControl);
mainTabControl.ResumeDrawing();
tabPageMessages.ResumeLayout();
ControlHelper.ResumeDrawing(tabPageMessages);
tabPageMessages.ResumeDrawing();
Cursor.Current = Cursors.Default;
}
}
Expand Down Expand Up @@ -1780,10 +1777,7 @@ private void ReadMessagesOneAtTheTime(bool peek, bool all, int count, IBrokeredM
messagesCustomPropertiesSplitContainer.Size.Width/2 - 8;
if (!peek)
{
if (OnRefresh != null)
{
OnRefresh();
}
OnRefresh?.Invoke();
}
if (mainTabControl.TabPages[MessagesTabPage] == null)
{
Expand Down Expand Up @@ -1830,7 +1824,7 @@ private void GetDeadletterMessages(bool peek, bool all, int count, IBrokeredMess
? MainForm.SingletonMainForm.TopCount
: count - totalRetrieved);
var enumerable = messages as BrokeredMessage[] ?? messages.ToArray();
retrieved = enumerable.Count();
retrieved = enumerable.Length;
if (retrieved == 0)
{
continue;
Expand All @@ -1854,7 +1848,7 @@ private void GetDeadletterMessages(bool peek, bool all, int count, IBrokeredMess
: count - totalRetrieved,
TimeSpan.FromSeconds(MainForm.SingletonMainForm.ReceiveTimeout));
var enumerable = messages as BrokeredMessage[] ?? messages.ToArray();
retrieved = enumerable.Count();
retrieved = enumerable.Length;
if (retrieved == 0)
{
continue;
Expand Down Expand Up @@ -1981,7 +1975,7 @@ private void GetTransferDeadletterMessages(bool peek, bool all, int count, IBrok
: count - totalRetrieved,
TimeSpan.FromSeconds(MainForm.SingletonMainForm.ReceiveTimeout));
var enumerable = messages as BrokeredMessage[] ?? messages.ToArray();
retrieved = enumerable.Count();
retrieved = enumerable.Length;
if (retrieved == 0)
{
continue;
Expand Down Expand Up @@ -2251,15 +2245,15 @@ private void btnCreateDelete_Click(object sender, EventArgs e)
return;
}

if (String.Equals(txtPath.Text.Trim(), txtForwardTo.Text.Trim(),
if (string.Equals(txtPath.Text.Trim(), txtForwardTo.Text.Trim(),
StringComparison.CurrentCultureIgnoreCase))
{
writeToLog(CannotForwardToItself);
txtForwardTo.Focus();
return;
}

if (String.Equals(txtPath.Text.Trim(), txtForwardDeadLetteredMessagesTo.Text.Trim(),
if (string.Equals(txtPath.Text.Trim(), txtForwardDeadLetteredMessagesTo.Text.Trim(),
StringComparison.CurrentCultureIgnoreCase))
{
writeToLog(CannotForwardDeadLetteredMessagesToItself);
Expand Down Expand Up @@ -2601,12 +2595,12 @@ private void btnCreateDelete_Click(object sender, EventArgs e)

private void HandleException(Exception ex)
{
if (ex == null || string.IsNullOrWhiteSpace(ex.Message))
if (string.IsNullOrWhiteSpace(ex?.Message))
{
return;
}
writeToLog(string.Format(CultureInfo.CurrentCulture, ExceptionFormat, ex.Message));
if (ex.InnerException != null && !string.IsNullOrWhiteSpace(ex.InnerException.Message))
if (!string.IsNullOrWhiteSpace(ex.InnerException?.Message))
{
writeToLog(string.Format(CultureInfo.CurrentCulture, InnerExceptionFormat, ex.InnerException.Message));
}
Expand Down Expand Up @@ -2640,16 +2634,13 @@ private void btnCancelUpdate_Click(object sender, EventArgs e)
{
if (btnCancelUpdate.Text == CancelText)
{
if (OnCancel != null)
{
OnCancel();
}
OnCancel?.Invoke();
}
else
{
try
{
if (String.Equals(txtPath.Text.Trim(), txtForwardTo.Text.Trim(),
if (string.Equals(txtPath.Text.Trim(), txtForwardTo.Text.Trim(),
StringComparison.CurrentCultureIgnoreCase))
{
writeToLog(CannotForwardToItself);
Expand Down Expand Up @@ -3614,7 +3605,7 @@ private void authorizationRulesDataGridView_Resize(object sender, EventArgs e)
{
try
{
ControlHelper.SuspendDrawing(authorizationRulesDataGridView);
authorizationRulesDataGridView.SuspendDrawing();
authorizationRulesDataGridView.SuspendLayout();
if (authorizationRulesDataGridView.Columns["IssuerName"] == null ||
authorizationRulesDataGridView.Columns["ClaimType"] == null ||
Expand All @@ -3634,7 +3625,7 @@ private void authorizationRulesDataGridView_Resize(object sender, EventArgs e)
authorizationRulesDataGridView.Columns["Listen"].Width -
authorizationRulesDataGridView.Columns["Revision"].Width -
authorizationRulesDataGridView.RowHeadersWidth;
var verticalScrollbar = Enumerable.OfType<VScrollBar>(authorizationRulesDataGridView.Controls).First();
var verticalScrollbar = authorizationRulesDataGridView.Controls.OfType<VScrollBar>().First();
if (verticalScrollbar.Visible)
{
width -= verticalScrollbar.Width;
Expand Down Expand Up @@ -3666,7 +3657,7 @@ private void authorizationRulesDataGridView_Resize(object sender, EventArgs e)
finally
{
authorizationRulesDataGridView.ResumeLayout();
ControlHelper.ResumeDrawing(authorizationRulesDataGridView);
authorizationRulesDataGridView.ResumeDrawing();
}
}

Expand Down Expand Up @@ -3735,7 +3726,7 @@ private void CalculateLastColumnWidth()
otherColumnsWidth += dataPointDataGridView.Columns[i].Width;
}
var width = dataPointDataGridView.Width - dataPointDataGridView.RowHeadersWidth - otherColumnsWidth;
var verticalScrollbar = Enumerable.OfType<VScrollBar>(dataPointDataGridView.Controls).First();
var verticalScrollbar = dataPointDataGridView.Controls.OfType<VScrollBar>().First();
if (verticalScrollbar.Visible)
{
width -= verticalScrollbar.Width;
Expand Down Expand Up @@ -3799,9 +3790,9 @@ private void btnMetrics_Click(object sender, EventArgs e)
}
if (metricTabPageIndexList.Count > 0)
{
for (var i = 0; i < metricTabPageIndexList.Count; i++)
foreach (var t in metricTabPageIndexList)
{
mainTabControl.TabPages.RemoveByKey(metricTabPageIndexList[i]);
mainTabControl.TabPages.RemoveByKey(t);
}
metricTabPageIndexList.Clear();
}
Expand Down Expand Up @@ -4073,7 +4064,7 @@ private void resubmitSelectedMessagesInBatchModeToolStripMenuItem_Click(object s
{
return;
}
using (var form = new MessageForm(Enumerable.Cast<DataGridViewRow>(messagesDataGridView.SelectedRows)
using (var form = new MessageForm(messagesDataGridView.SelectedRows.Cast<DataGridViewRow>()
.Select(r => (BrokeredMessage) r.DataBoundItem), serviceBusHelper, writeToLog))
{
form.ShowDialog();
Expand Down Expand Up @@ -4229,15 +4220,15 @@ private void pictFindMessages_Click(object sender, EventArgs e)
finally
{
messagesDataGridView.ResumeLayout();
ControlHelper.ResumeDrawing(messagesDataGridView);
messagesDataGridView.ResumeDrawing();
}
}

private void pictFindDeadletter_Click(object sender, EventArgs e)
{
try
{
ControlHelper.SuspendDrawing(deadletterDataGridView);
deadletterDataGridView.SuspendDrawing();
deadletterDataGridView.SuspendLayout();
if (deadletterBindingList == null)
{
Expand Down Expand Up @@ -4294,7 +4285,7 @@ private void pictFindDeadletter_Click(object sender, EventArgs e)
finally
{
deadletterDataGridView.ResumeLayout();
ControlHelper.ResumeDrawing(deadletterDataGridView);
deadletterDataGridView.ResumeDrawing();
}
}

Expand Down Expand Up @@ -4362,9 +4353,9 @@ protected override void Dispose(bool disposing)
{
try
{
if (disposing && (components != null))
if (disposing)
{
components.Dispose();
components?.Dispose();
}

for (var i = 0; i < Controls.Count; i++)
Expand Down Expand Up @@ -4431,7 +4422,7 @@ private void saveSelectedMessagesToolStripMenuItem_Click(object sender, EventArg
return;
}
var messages =
Enumerable.Cast<DataGridViewRow>(messagesDataGridView.SelectedRows)
messagesDataGridView.SelectedRows.Cast<DataGridViewRow>()
.Select(r => r.DataBoundItem as BrokeredMessage);
IEnumerable<BrokeredMessage> brokeredMessages = messages as BrokeredMessage[] ?? messages.ToArray();
if (!brokeredMessages.Any())
Expand Down Expand Up @@ -4643,9 +4634,9 @@ private void btnCloseTabs_Click(object sender, EventArgs e)
{
return;
}
for (var i = 0; i < metricTabPageIndexList.Count; i++)
foreach (string t in metricTabPageIndexList)
{
mainTabControl.TabPages.RemoveByKey(metricTabPageIndexList[i]);
mainTabControl.TabPages.RemoveByKey(t);
}
metricTabPageIndexList.Clear();
btnCloseTabs.Enabled = false;
Expand Down
Loading

0 comments on commit a8a0adc

Please sign in to comment.