Skip to content
GitLab
Menu
Projects
Groups
Snippets
/
Help
Help
Support
Community forum
Keyboard shortcuts
?
Submit feedback
Sign in / Register
Toggle navigation
Menu
Open sidebar
Open Subsurface Data Universe Software
Platform
Data Flow
Data Enrichment
wks
Commits
e08b2f44
Commit
e08b2f44
authored
Aug 19, 2020
by
harshit aggarwal
Browse files
Removing unused imports
parent
10532ea0
Pipeline
#6124
failed with stages
in 2 minutes and 38 seconds
Changes
5
Pipelines
5
Hide whitespace changes
Inline
Side-by-side
provider/wks-azure/src/main/java/org/opengroup/osdu/wks/provider/azure/pubsub/MessageHandler.java
View file @
e08b2f44
...
...
@@ -4,7 +4,6 @@ import com.microsoft.azure.servicebus.ExceptionPhase;
import
com.microsoft.azure.servicebus.IMessage
;
import
com.microsoft.azure.servicebus.IMessageHandler
;
import
com.microsoft.azure.servicebus.SubscriptionClient
;
import
org.opengroup.osdu.wks.provider.azure.di.AzureBootstrapConfig
;
import
java.util.concurrent.CompletableFuture
;
import
org.slf4j.Logger
;
...
...
@@ -15,12 +14,10 @@ public class MessageHandler implements IMessageHandler {
private
final
static
Logger
LOGGER
=
LoggerFactory
.
getLogger
(
MessageHandler
.
class
);
private
final
SubscriptionClient
receiveClient
;
private
final
ProcessWKSTransform
processWKSTransform
;
private
final
AzureBootstrapConfig
azureBootstrapConfig
;
public
MessageHandler
(
SubscriptionClient
client
,
ProcessWKSTransform
processWKSTransform
,
AzureBootstrapConfig
azureBootstrapConfig
)
{
public
MessageHandler
(
SubscriptionClient
client
,
ProcessWKSTransform
processWKSTransform
)
{
this
.
receiveClient
=
client
;
this
.
processWKSTransform
=
processWKSTransform
;
this
.
azureBootstrapConfig
=
azureBootstrapConfig
;
}
@Override
...
...
provider/wks-azure/src/main/java/org/opengroup/osdu/wks/provider/azure/pubsub/ProcessWKSTransform.java
View file @
e08b2f44
...
...
@@ -8,7 +8,6 @@ import org.opengroup.osdu.core.common.model.http.DpsHeaders;
import
org.opengroup.osdu.wks.exceptions.ApplicationException
;
import
org.opengroup.osdu.wks.exceptions.BadRequestException
;
import
org.opengroup.osdu.wks.model.RawRecordDetails
;
import
org.opengroup.osdu.wks.provider.azure.di.AzureBootstrapConfig
;
import
org.opengroup.osdu.wks.provider.azure.utils.MDCContextMap
;
import
org.opengroup.osdu.wks.service.WKSService
;
import
org.slf4j.Logger
;
...
...
@@ -29,9 +28,6 @@ public class ProcessWKSTransform {
@Autowired
private
WKSService
wKSService
;
@Autowired
private
AzureBootstrapConfig
azureBootstrapConfig
;
@Autowired
private
MDCContextMap
mdcContextMap
;
...
...
provider/wks-azure/src/main/java/org/opengroup/osdu/wks/provider/azure/pubsub/SubscriptionManagerImpl.java
View file @
e08b2f44
...
...
@@ -39,7 +39,7 @@ public class SubscriptionManagerImpl implements SubscriptionManager {
private
void
registerMessageHandler
(
SubscriptionClient
subscriptionClient
,
ExecutorService
executorService
)
{
try
{
MessageHandler
messageHandler
=
new
MessageHandler
(
subscriptionClient
,
processWKSTransform
,
azureBootstrapConfig
);
MessageHandler
messageHandler
=
new
MessageHandler
(
subscriptionClient
,
processWKSTransform
);
subscriptionClient
.
registerMessageHandler
(
messageHandler
,
...
...
provider/wks-azure/src/main/java/org/opengroup/osdu/wks/provider/azure/storage/MappingStoreImpl.java
View file @
e08b2f44
...
...
@@ -4,7 +4,6 @@ import com.fasterxml.jackson.databind.ObjectMapper;
import
org.opengroup.osdu.azure.blobstorage.BlobStore
;
import
org.opengroup.osdu.core.common.model.http.DpsHeaders
;
import
org.opengroup.osdu.wks.model.MappingsModel
;
import
org.opengroup.osdu.wks.provider.azure.di.AzureBootstrapConfig
;
import
org.opengroup.osdu.wks.provider.interfaces.MappingStore
;
import
org.slf4j.Logger
;
import
org.slf4j.LoggerFactory
;
...
...
@@ -20,9 +19,6 @@ public class MappingStoreImpl implements MappingStore {
@Autowired
private
BlobStore
blobStore
;
@Autowired
private
AzureBootstrapConfig
azureBootstrapConfig
;
@Override
public
MappingsModel
getMapping
(
final
String
fileName
)
{
MappingsModel
mappings
=
null
;
...
...
provider/wks-azure/src/test/java/org/opengroup/osdu/wks/provider/azure/pubsub/ProcessWKSTransformTest.java
View file @
e08b2f44
...
...
@@ -26,7 +26,6 @@ import org.opengroup.osdu.core.common.model.http.DpsHeaders;
import
org.opengroup.osdu.wks.exceptions.ApplicationException
;
import
org.opengroup.osdu.wks.exceptions.BadRequestException
;
import
org.opengroup.osdu.wks.model.RawRecordDetails
;
import
org.opengroup.osdu.wks.provider.azure.di.AzureBootstrapConfig
;
import
org.opengroup.osdu.wks.provider.azure.utils.MDCContextMap
;
import
org.opengroup.osdu.wks.service.WKSService
;
...
...
@@ -62,9 +61,6 @@ public class ProcessWKSTransformTest {
@Mock
private
Message
message
;
@Mock
private
AzureBootstrapConfig
azureBootstrapConfig
;
@Mock
private
MDCContextMap
mdcContextMap
;
...
...
Write
Preview
Supports
Markdown
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