Commit d29a5788 authored by Komal Makkar's avatar Komal Makkar
Browse files

changed sneaky throws

parent c6de6de1
Pipeline #29694 failed with stage
in 1 minute and 16 seconds
...@@ -17,12 +17,11 @@ package org.opengroup.osdu.azure.eventgrid; ...@@ -17,12 +17,11 @@ package org.opengroup.osdu.azure.eventgrid;
import com.microsoft.azure.eventgrid.EventGridClient; import com.microsoft.azure.eventgrid.EventGridClient;
import com.microsoft.azure.eventgrid.TopicCredentials; import com.microsoft.azure.eventgrid.TopicCredentials;
import com.microsoft.azure.eventgrid.implementation.EventGridClientImpl; import com.microsoft.azure.eventgrid.implementation.EventGridClientImpl;
import lombok.SneakyThrows;
import org.opengroup.osdu.azure.cache.EventGridTopicClientCache; import org.opengroup.osdu.azure.cache.EventGridTopicClientCache;
import org.opengroup.osdu.azure.cosmosdb.CosmosStoreBulkOperations;
import org.opengroup.osdu.azure.partition.EventGridTopicPartitionInfoAzure; import org.opengroup.osdu.azure.partition.EventGridTopicPartitionInfoAzure;
import org.opengroup.osdu.azure.partition.PartitionServiceEventGridClient; import org.opengroup.osdu.azure.partition.PartitionServiceEventGridClient;
import org.opengroup.osdu.common.Validators; import org.opengroup.osdu.common.Validators;
import org.opengroup.osdu.core.common.partition.PartitionException;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
...@@ -42,13 +41,14 @@ public class EventGridTopicClientFactoryImpl implements IEventGridTopicClientFac ...@@ -42,13 +41,14 @@ public class EventGridTopicClientFactoryImpl implements IEventGridTopicClientFac
private EventGridTopicClientCache clientCache; private EventGridTopicClientCache clientCache;
/** /**
*
* @param dataPartitionId Data partition id * @param dataPartitionId Data partition id
* @param topicName Topic Name * @param topicName Topic name
* @return EventGridClient * @return EventGridClient
* @throws PartitionException partitionException
*/ */
@SneakyThrows
@Override @Override
public EventGridClient getClient(final String dataPartitionId, final String topicName) { public EventGridClient getClient(final String dataPartitionId, final String topicName) throws PartitionException {
Validators.checkNotNullAndNotEmpty(dataPartitionId, "dataPartitionId"); Validators.checkNotNullAndNotEmpty(dataPartitionId, "dataPartitionId");
Validators.checkNotNull(topicName, "topicName"); Validators.checkNotNull(topicName, "topicName");
......
...@@ -15,6 +15,7 @@ ...@@ -15,6 +15,7 @@
package org.opengroup.osdu.azure.eventgrid; package org.opengroup.osdu.azure.eventgrid;
import com.microsoft.azure.eventgrid.EventGridClient; import com.microsoft.azure.eventgrid.EventGridClient;
import org.opengroup.osdu.core.common.partition.PartitionException;
/** /**
* Interface for Event Grid Topic client factory to return appropriate * Interface for Event Grid Topic client factory to return appropriate
...@@ -23,9 +24,11 @@ import com.microsoft.azure.eventgrid.EventGridClient; ...@@ -23,9 +24,11 @@ import com.microsoft.azure.eventgrid.EventGridClient;
public interface IEventGridTopicClientFactory { public interface IEventGridTopicClientFactory {
/** /**
*
* @param dataPartitionId Data partition id * @param dataPartitionId Data partition id
* @param topicName Topic name * @param topicName Topic name
* @return EventGridClient * @return EventGridClient
* @throws PartitionException partitionException
*/ */
EventGridClient getClient(String dataPartitionId, String topicName); EventGridClient getClient(String dataPartitionId, String topicName) throws PartitionException;
} }
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment