Skip to content
Toggle navigation
P
Projects
G
Groups
S
Snippets
Help
ipgallery.common.java
/
microservice
This project
Loading...
Sign in
Toggle navigation
Go to a project
Project
Repository
Registry
Issues
0
Merge Requests
0
Pipelines
Wiki
Settings
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Charts
Commit
bebbfb0f
authored
Jan 17, 2018
by
Amir Aharon
Browse files
Options
_('Browse Files')
Download
Email Patches
Plain Diff
allow null logger
parent
92c60bc4
Show whitespace changes
Inline
Side-by-side
Showing
3 changed files
with
9 additions
and
4 deletions
src/main/java/microservice/services/IRestServiceHttpImpl.java
src/main/java/microservice/services/IRestServiceZmqImpl.java
src/main/java/microservice/services/protocol/zmq/IMsgQServiceZmqImpl.java
src/main/java/microservice/services/IRestServiceHttpImpl.java
View file @
bebbfb0f
...
...
@@ -145,9 +145,12 @@ public class IRestServiceHttpImpl extends CommonServices.IRestService implements
@Override
public
boolean
init
()
{
boolean
stat
=
true
;
if
(
MicroserviceApp
.
getsInstance
()
!=
null
)
{
msAppInstance
=
MicroserviceApp
.
getsInstance
();
logger
=
msAppInstance
.
getLogger
();
this
.
appName
=
msAppInstance
.
getAppName
();
}
switch
(
getServiceMode
()){
case
E_CLIENT:
break
;
...
...
src/main/java/microservice/services/IRestServiceZmqImpl.java
View file @
bebbfb0f
...
...
@@ -826,8 +826,10 @@ public class IRestServiceZmqImpl extends CommonServices.IRestService implements
@Override
public
boolean
init
()
{
boolean
retstat
=
true
;
if
(
MicroserviceApp
.
getsInstance
()
!=
null
)
{
this
.
appName
=
MicroserviceApp
.
getsInstance
().
getAppName
();
this
.
logger
=
MicroserviceApp
.
getsInstance
().
getLogger
();
}
switch
(
getServiceMode
()){
case
E_CLIENT:
...
...
src/main/java/microservice/services/protocol/zmq/IMsgQServiceZmqImpl.java
View file @
bebbfb0f
...
...
@@ -97,13 +97,13 @@ public class IMsgQServiceZmqImpl extends CommonServices.IMsgQService {
retstat
=
allocateClient
();
break
;
case
E_SERVER:
retstat
=
allocateServer
();
retstat
=
(
allocateServer
()
&&
!
allWorkersList
.
isEmpty
()
&&
allWorkersList
.
stream
().
allMatch
(
CommonServices
.
IWorker
::
init
));
break
;
}
return
(
retstat
&&
!
allWorkersList
.
isEmpty
()
&&
allWorkersList
.
stream
().
allMatch
(
CommonServices
.
IWorker
::
init
));
return
retstat
;
}
else
{
System
.
err
.
println
(
getClass
().
getName
()
+
" >> unknown service mode"
);
retstat
=
false
;
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment