Loading sharding-core/src/main/java/io/shardingsphere/core/orche/eventbus/state/disabled/DisabledStateEventBusEvent.java 0 → 100644 +35 −0 Original line number Diff line number Diff line /* * Copyright 2016-2018 shardingsphere.io. * <p> * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. * </p> */ package io.shardingsphere.core.orche.eventbus.state.disabled; import lombok.Getter; import lombok.RequiredArgsConstructor; import java.util.Collection; /** * JDBC disabled event bus event. * * @author panjuan */ @RequiredArgsConstructor @Getter public final class DisabledStateEventBusEvent { private final Collection<String> disabledDataSourceNames; } sharding-core/src/main/java/io/shardingsphere/core/orche/eventbus/state/disabled/DisabledStateEventBusInstance.java 0 → 100644 +42 −0 Original line number Diff line number Diff line /* * Copyright 2016-2018 shardingsphere.io. * <p> * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. * </p> */ package io.shardingsphere.core.orche.eventbus.state.disabled; import com.google.common.eventbus.EventBus; import lombok.AccessLevel; import lombok.NoArgsConstructor; /** * Jdbc disabled event bus instance. * * @author panjuan */ @NoArgsConstructor(access = AccessLevel.PRIVATE) public final class DisabledStateEventBusInstance { private static final EventBus INSTANCE = new EventBus(); /** * Get event bus instance. * * @return event bus instance */ public static EventBus getInstance() { return INSTANCE; } } Loading
sharding-core/src/main/java/io/shardingsphere/core/orche/eventbus/state/disabled/DisabledStateEventBusEvent.java 0 → 100644 +35 −0 Original line number Diff line number Diff line /* * Copyright 2016-2018 shardingsphere.io. * <p> * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. * </p> */ package io.shardingsphere.core.orche.eventbus.state.disabled; import lombok.Getter; import lombok.RequiredArgsConstructor; import java.util.Collection; /** * JDBC disabled event bus event. * * @author panjuan */ @RequiredArgsConstructor @Getter public final class DisabledStateEventBusEvent { private final Collection<String> disabledDataSourceNames; }
sharding-core/src/main/java/io/shardingsphere/core/orche/eventbus/state/disabled/DisabledStateEventBusInstance.java 0 → 100644 +42 −0 Original line number Diff line number Diff line /* * Copyright 2016-2018 shardingsphere.io. * <p> * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. * </p> */ package io.shardingsphere.core.orche.eventbus.state.disabled; import com.google.common.eventbus.EventBus; import lombok.AccessLevel; import lombok.NoArgsConstructor; /** * Jdbc disabled event bus instance. * * @author panjuan */ @NoArgsConstructor(access = AccessLevel.PRIVATE) public final class DisabledStateEventBusInstance { private static final EventBus INSTANCE = new EventBus(); /** * Get event bus instance. * * @return event bus instance */ public static EventBus getInstance() { return INSTANCE; } }