File tree Expand file tree Collapse file tree 3 files changed +9
-7
lines changed
src/main/java/com/wesley/bloblib Expand file tree Collapse file tree 3 files changed +9
-7
lines changed Original file line number Diff line number Diff line change 44
55 <groupId >com.wesley</groupId >
66 <artifactId >bloblib</artifactId >
7- <version >1.0 .0</version >
7+ <version >1.1 .0</version >
88 <name >A blob operation library built on top of azure blob service</name >
99 <packaging >jar</packaging >
1010 <url >http://maven.apache.org</url >
Original file line number Diff line number Diff line change @@ -137,9 +137,9 @@ private class MsgAutoPorcessor implements Runnable{
137137 @ SuppressWarnings ("static-access" )
138138 @ Override
139139 public void run () {
140- try {
140+ while ( true ) {
141141 /* start the auto cleanup process */
142- while ( true ) {
142+ try {
143143 //CachedFilesInMemManager bfsFilesCache = CachedFilesInMemManager.getInstance();
144144 /* Retrieve the msgs from the service bus topic */
145145 ArrayList <String > msgs = new ArrayList <>();
@@ -154,10 +154,12 @@ public void run() {
154154 msg = MessageService .getInstance ().buildProcessedMsgToBeSent (msg );
155155 MessageService .getInstance ().sendMessage (msg );
156156 }
157- Thread .sleep (Constants .DEFAULT_BFC_THREAD_SLEEP_MILLS );
158- }
159- } catch (Exception ex ) {
160- Logger .error (ex .getMessage ());
157+
158+ } catch (Exception ex ) {
159+ Logger .error (ex .getMessage ());
160+ }
161+ try { Thread .sleep (Constants .DEFAULT_BFC_THREAD_SLEEP_MILLS );
162+ } catch (InterruptedException e ) {}
161163 }
162164 }
163165
You can’t perform that action at this time.
0 commit comments