Skip to content
Projects
Groups
Snippets
Help
Loading...
Help
Contribute to GitLab
Sign in
Toggle navigation
T
TDLCloud
Project
Project
Details
Activity
Cycle Analytics
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Charts
Issues
0
Issues
0
List
Board
Labels
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Charts
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
WitCloud
TDLCloud
Commits
1caf261c
Commit
1caf261c
authored
Mar 13, 2018
by
wangjunqiangs
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
add out ignore
parent
ac52f6a0
Show whitespace changes
Inline
Side-by-side
Showing
8 changed files
with
58 additions
and
106 deletions
+58
-106
.gitignore
.gitignore
+1
-0
GWConfigWorker.java
...ain/java/com/example/tdl/callabletask/GWConfigWorker.java
+10
-0
ThreadPoolConfiguration.java
.../java/com/example/tdl/config/ThreadPoolConfiguration.java
+10
-0
MqttConfig.java
src/main/java/com/example/tdl/config/mqtt/MqttConfig.java
+10
-0
MqttTemlateAsync.java
...in/java/com/example/tdl/config/mqtt/MqttTemlateAsync.java
+10
-0
package-info.java
src/main/java/com/example/tdl/config/mqtt/package-info.java
+7
-0
MqttConfig.java
src/main/java/com/example/tdl/mqtt/MqttConfig.java
+0
-106
MqttListener.java
src/main/java/com/example/tdl/mqtt/MqttListener.java
+10
-0
No files found.
.gitignore
View file @
1caf261c
...
@@ -26,3 +26,4 @@ nbdist/
...
@@ -26,3 +26,4 @@ nbdist/
## log ##
## log ##
*.log
*.log
out/
src/main/java/com/example/tdl/callabletask/GWConfigWorker.java
0 → 100644
View file @
1caf261c
package
com
.
example
.
tdl
.
callabletask
;
/**
* @Author: lelouch
* @Description:
* @Date: Created in 9:34 2018/3/13
* @Modified By:
**/
public
class
GWConfigWorker
{
}
src/main/java/com/example/tdl/config/ThreadPoolConfiguration.java
0 → 100644
View file @
1caf261c
package
com
.
example
.
tdl
.
config
;
/**
* @Author: lelouch
* @Description:
* @Date: Created in 9:38 2018/3/13
* @Modified By:
**/
public
class
ThreadPoolConfiguration
{
}
src/main/java/com/example/tdl/config/mqtt/MqttConfig.java
0 → 100644
View file @
1caf261c
package
com
.
example
.
tdl
.
config
.
mqtt
;
/**
* @Author: lelouch
* @Description:
* @Date: Created in 9:25 2018/3/13
* @Modified By:
**/
public
class
MqttConfig
{
}
src/main/java/com/example/tdl/config/mqtt/MqttTemlateAsync.java
0 → 100644
View file @
1caf261c
package
com
.
example
.
tdl
.
config
.
mqtt
;
/**
* @Author: lelouch
* @Description:
* @Date: Created in 9:29 2018/3/13
* @Modified By:
**/
public
class
MqttTemlateAsync
{
}
src/main/java/com/example/tdl/config/mqtt/package-info.java
0 → 100644
View file @
1caf261c
/**
* @Author: lelouch
* @Description:
* @Date: Created in 9:24 2018/3/13
* @Modified By:
**/
package
com
.
example
.
tdl
.
config
.
mqtt
;
\ No newline at end of file
src/main/java/com/example/tdl/mqtt/MqttConfig.java
deleted
100644 → 0
View file @
ac52f6a0
package
com
.
example
.
tdl
.
mqtt
;
import
org.springframework.boot.context.properties.ConfigurationProperties
;
import
org.springframework.context.annotation.Configuration
;
@Configuration
@ConfigurationProperties
(
prefix
=
"tdl.mqtt"
)
public
class
MqttConfig
{
private
String
url
;
private
String
port
;
private
String
username
;
private
String
password
;
private
String
qos
;
private
String
clientPubId
;
private
String
clientSubId
;
private
String
clientSubTopic
;
private
Boolean
useCredential
;
public
String
getUrl
()
{
return
url
;
}
public
void
setUrl
(
String
url
)
{
this
.
url
=
url
;
}
public
String
getPort
()
{
return
port
;
}
public
void
setPort
(
String
port
)
{
this
.
port
=
port
;
}
public
String
getUsername
()
{
return
username
;
}
public
void
setUsername
(
String
username
)
{
this
.
username
=
username
;
}
public
String
getPassword
()
{
return
password
;
}
public
void
setPassword
(
String
password
)
{
this
.
password
=
password
;
}
public
String
getQos
()
{
return
qos
;
}
public
void
setQos
(
String
qos
)
{
this
.
qos
=
qos
;
}
public
String
getClientPubId
()
{
return
clientPubId
;
}
public
void
setClientPubId
(
String
clientPubId
)
{
this
.
clientPubId
=
clientPubId
;
}
public
String
getClientSubId
()
{
return
clientSubId
;
}
public
void
setClientSubId
(
String
clientSubId
)
{
this
.
clientSubId
=
clientSubId
;
}
public
String
getClientSubTopic
()
{
return
clientSubTopic
;
}
public
void
setClientSubTopic
(
String
clientSubTopic
)
{
this
.
clientSubTopic
=
clientSubTopic
;
}
public
Boolean
getUseCredential
()
{
return
useCredential
;
}
public
void
setUseCredential
(
Boolean
useCredential
)
{
this
.
useCredential
=
useCredential
;
}
/* @Bean
public MqttTemplate mqttTemplate() throws MqttException {
MqttTemplate mqttTemplate =null;
try {
mqttTemplate = new MqttTemplate(this.url+":"+this.port,"witiumcloud");
mqttTemplate.connect(MqttTemplate.setOptions(this.username,this.password));
System.out.println("Mqtt connected with mqtt broker at url : 120.27.235.39:1883");
}catch (MqttException e)
{
e.printStackTrace();
}
return mqttTemplate;
}*/
}
src/main/java/com/example/tdl/mqtt/MqttListener.java
0 → 100644
View file @
1caf261c
package
com
.
example
.
tdl
.
mqtt
;
/**
* @Author: lelouch
* @Description:
* @Date: Created in 9:41 2018/3/13
* @Modified By:
**/
public
class
MqttListener
{
}
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